See <https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk8/478/display/redirect?page=changes>
Changes: [github] MINOR: Improve confusing admin client shutdown logging (#10107) ------------------------------------------ [...truncated 3.59 MB...] SocketServerTest > remoteCloseWithIncompleteBufferedReceive() PASSED SocketServerTest > testStagedListenerShutdownWhenConnectionQueueIsFull() STARTED SocketServerTest > testStagedListenerShutdownWhenConnectionQueueIsFull() PASSED SocketServerTest > testStagedListenerStartup() STARTED SocketServerTest > testStagedListenerStartup() PASSED SocketServerTest > testConnectionRateLimit() STARTED SocketServerTest > testConnectionRateLimit() PASSED SocketServerTest > testConnectionRatePerIp() STARTED SocketServerTest > testConnectionRatePerIp() PASSED SocketServerTest > processCompletedSendException() STARTED SocketServerTest > processCompletedSendException() PASSED SocketServerTest > processDisconnectedException() STARTED SocketServerTest > processDisconnectedException() PASSED SocketServerTest > closingChannelWithBufferedReceives() STARTED SocketServerTest > closingChannelWithBufferedReceives() PASSED SocketServerTest > sendCancelledKeyException() STARTED SocketServerTest > sendCancelledKeyException() PASSED SocketServerTest > processCompletedReceiveException() STARTED SocketServerTest > processCompletedReceiveException() PASSED SocketServerTest > testControlPlaneAsPrivilegedListener() STARTED SocketServerTest > testControlPlaneAsPrivilegedListener() PASSED SocketServerTest > closingChannelSendFailure() STARTED SocketServerTest > closingChannelSendFailure() PASSED SocketServerTest > idleExpiryWithBufferedReceives() STARTED SocketServerTest > idleExpiryWithBufferedReceives() PASSED SocketServerTest > testSocketsCloseOnShutdown() STARTED SocketServerTest > testSocketsCloseOnShutdown() PASSED SocketServerTest > testNoOpActionResponseWithThrottledChannelWhereThrottlingAlreadyDone() STARTED SocketServerTest > testNoOpActionResponseWithThrottledChannelWhereThrottlingAlreadyDone() PASSED SocketServerTest > pollException() STARTED SocketServerTest > pollException() PASSED SocketServerTest > closingChannelWithBufferedReceivesFailedSend() STARTED SocketServerTest > closingChannelWithBufferedReceivesFailedSend() PASSED SocketServerTest > remoteCloseWithBufferedReceives() STARTED SocketServerTest > remoteCloseWithBufferedReceives() PASSED SocketServerTest > testThrottledSocketsClosedOnShutdown() STARTED SocketServerTest > testThrottledSocketsClosedOnShutdown() PASSED SocketServerTest > closingChannelWithCompleteAndIncompleteBufferedReceives() STARTED SocketServerTest > closingChannelWithCompleteAndIncompleteBufferedReceives() PASSED SocketServerTest > testInterBrokerListenerAsPrivilegedListener() STARTED SocketServerTest > testInterBrokerListenerAsPrivilegedListener() PASSED SocketServerTest > testSslSocketServer() STARTED SocketServerTest > testSslSocketServer() PASSED SocketServerTest > testDisabledRequestIsRejected() STARTED SocketServerTest > testDisabledRequestIsRejected() PASSED SocketServerTest > tooBigRequestIsRejected() STARTED SocketServerTest > tooBigRequestIsRejected() PASSED SocketServerTest > testNoOpActionResponseWithThrottledChannelWhereThrottlingInProgress() STARTED SocketServerTest > testNoOpActionResponseWithThrottledChannelWhereThrottlingInProgress() PASSED DynamicConnectionQuotaTest > testDynamicConnectionQuota() STARTED DynamicConnectionQuotaTest > testDynamicConnectionQuota() PASSED DynamicConnectionQuotaTest > testDynamicListenerConnectionQuota() STARTED DynamicConnectionQuotaTest > testDynamicListenerConnectionQuota() PASSED DynamicConnectionQuotaTest > testDynamicListenerConnectionCreationRateQuota() STARTED DynamicConnectionQuotaTest > testDynamicListenerConnectionCreationRateQuota() PASSED DynamicConnectionQuotaTest > testDynamicIpConnectionRateQuota() STARTED DynamicConnectionQuotaTest > testDynamicIpConnectionRateQuota() PASSED DefaultMessageFormatterTest > [1] name=print nothing, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@49ef8392, value = [B@79f975dd), properties=Map(print.value -> false), expected= STARTED DefaultMessageFormatterTest > [1] name=print nothing, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@49ef8392, value = [B@79f975dd), properties=Map(print.value -> false), expected= PASSED DefaultMessageFormatterTest > [2] name=print key, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@57886d2f, value = [B@3ffa03ae), properties=Map(print.key -> true, print.value -> false), expected=someKey STARTED DefaultMessageFormatterTest > [2] name=print key, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@57886d2f, value = [B@3ffa03ae), properties=Map(print.key -> true, print.value -> false), expected=someKey PASSED DefaultMessageFormatterTest > [3] name=print value, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@35d1d476, value = [B@3dea5ab5), properties=Map(), expected=someValue STARTED DefaultMessageFormatterTest > [3] name=print value, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@35d1d476, value = [B@3dea5ab5), properties=Map(), expected=someValue PASSED DefaultMessageFormatterTest > [4] name=print empty timestamp, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, NoTimestampType = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@299fa932, value = [B@461728dc), properties=Map(print.timestamp -> true, print.value -> false), expected=NO_TIMESTAMP STARTED DefaultMessageFormatterTest > [4] name=print empty timestamp, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, NoTimestampType = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@299fa932, value = [B@461728dc), properties=Map(print.timestamp -> true, print.value -> false), expected=NO_TIMESTAMP PASSED DefaultMessageFormatterTest > [5] name=print log append time timestamp, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, LogAppendTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@7dde260c, value = [B@128ee4f0), properties=Map(print.timestamp -> true, print.value -> false), expected=LogAppendTime:1234 STARTED DefaultMessageFormatterTest > [5] name=print log append time timestamp, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, LogAppendTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@7dde260c, value = [B@128ee4f0), properties=Map(print.timestamp -> true, print.value -> false), expected=LogAppendTime:1234 PASSED DefaultMessageFormatterTest > [6] name=print create time timestamp, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@460c09aa, value = [B@3922987f), properties=Map(print.timestamp -> true, print.value -> false), expected=CreateTime:1234 STARTED DefaultMessageFormatterTest > [6] name=print create time timestamp, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@460c09aa, value = [B@3922987f), properties=Map(print.timestamp -> true, print.value -> false), expected=CreateTime:1234 PASSED DefaultMessageFormatterTest > [7] name=print partition, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@35403711, value = [B@508cec2d), properties=Map(print.partition -> true, print.value -> false), expected=Partition:9 STARTED DefaultMessageFormatterTest > [7] name=print partition, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@35403711, value = [B@508cec2d), properties=Map(print.partition -> true, print.value -> false), expected=Partition:9 PASSED DefaultMessageFormatterTest > [8] name=print offset, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@76ebeecf, value = [B@5b27710d), properties=Map(print.offset -> true, print.value -> false), expected=Offset:9876 STARTED DefaultMessageFormatterTest > [8] name=print offset, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@76ebeecf, value = [B@5b27710d), properties=Map(print.offset -> true, print.value -> false), expected=Offset:9876 PASSED DefaultMessageFormatterTest > [9] name=print headers, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@6f6b2dc7, value = [B@58314983), properties=Map(print.headers -> true, print.value -> false), expected=h1:v1,h2:v2 STARTED DefaultMessageFormatterTest > [9] name=print headers, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@6f6b2dc7, value = [B@58314983), properties=Map(print.headers -> true, print.value -> false), expected=h1:v1,h2:v2 PASSED DefaultMessageFormatterTest > [10] name=print empty headers, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [], isReadOnly = false), key = [B@114ae1e8, value = [B@2779e313), properties=Map(print.headers -> true, print.value -> false), expected=NO_HEADERS STARTED DefaultMessageFormatterTest > [10] name=print empty headers, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [], isReadOnly = false), key = [B@114ae1e8, value = [B@2779e313), properties=Map(print.headers -> true, print.value -> false), expected=NO_HEADERS PASSED DefaultMessageFormatterTest > [11] name=print all possible fields with default delimiters, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@7556db2e, value = [B@2ec6b7e1), properties=Map(print.key -> true, print.headers -> true, print.partition -> true, print.offset -> true, print.timestamp -> true, print.value -> true), expected=CreateTime:1234 Partition:9 Offset:9876 h1:v1,h2:v2 someKey someValue STARTED DefaultMessageFormatterTest > [11] name=print all possible fields with default delimiters, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@7556db2e, value = [B@2ec6b7e1), properties=Map(print.key -> true, print.headers -> true, print.partition -> true, print.offset -> true, print.timestamp -> true, print.value -> true), expected=CreateTime:1234 Partition:9 Offset:9876 h1:v1,h2:v2 someKey someValue PASSED DefaultMessageFormatterTest > [12] name=print all possible fields with custom delimiters, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@68454670, value = [B@4c5110), properties=Map(line.separator -> ^, print.key -> true, headers.separator -> #, print.headers -> true, key.separator -> |, print.partition -> true, print.offset -> true, print.timestamp -> true, print.value -> true), expected=CreateTime:1234|Partition:9|Offset:9876|h1:v1#h2:v2|someKey|someValue^ STARTED DefaultMessageFormatterTest > [12] name=print all possible fields with custom delimiters, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@68454670, value = [B@4c5110), properties=Map(line.separator -> ^, print.key -> true, headers.separator -> #, print.headers -> true, key.separator -> |, print.partition -> true, print.offset -> true, print.timestamp -> true, print.value -> true), expected=CreateTime:1234|Partition:9|Offset:9876|h1:v1#h2:v2|someKey|someValue^ PASSED DefaultMessageFormatterTest > [13] name=print key with custom deserializer, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@4380759c, value = [B@5862bbb2), properties=Map(print.key -> true, print.headers -> true, print.value -> true, key.deserializer -> unit.kafka.tools.UpperCaseDeserializer), expected=h1:v1,h2:v2 SOMEKEY someValue STARTED DefaultMessageFormatterTest > [13] name=print key with custom deserializer, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@4380759c, value = [B@5862bbb2), properties=Map(print.key -> true, print.headers -> true, print.value -> true, key.deserializer -> unit.kafka.tools.UpperCaseDeserializer), expected=h1:v1,h2:v2 SOMEKEY someValue PASSED DefaultMessageFormatterTest > [14] name=print value with custom deserializer, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@78f01683, value = [B@389cb094), properties=Map(print.key -> true, print.headers -> true, print.value -> true, value.deserializer -> unit.kafka.tools.UpperCaseDeserializer), expected=h1:v1,h2:v2 someKey SOMEVALUE STARTED DefaultMessageFormatterTest > [14] name=print value with custom deserializer, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@78f01683, value = [B@389cb094), properties=Map(print.key -> true, print.headers -> true, print.value -> true, value.deserializer -> unit.kafka.tools.UpperCaseDeserializer), expected=h1:v1,h2:v2 someKey SOMEVALUE PASSED DefaultMessageFormatterTest > [15] name=print headers with custom deserializer, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@75ee331e, value = [B@5f12bbfb), properties=Map(print.key -> true, print.headers -> true, print.value -> true, headers.deserializer -> unit.kafka.tools.UpperCaseDeserializer), expected=h1:V1,h2:V2 someKey someValue STARTED DefaultMessageFormatterTest > [15] name=print headers with custom deserializer, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@75ee331e, value = [B@5f12bbfb), properties=Map(print.key -> true, print.headers -> true, print.value -> true, headers.deserializer -> unit.kafka.tools.UpperCaseDeserializer), expected=h1:V1,h2:V2 someKey someValue PASSED DefaultMessageFormatterTest > [16] name=print key and value, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@272efa94, value = [B@7a6bf6f5), properties=Map(print.key -> true, print.value -> true), expected=someKey someValue STARTED DefaultMessageFormatterTest > [16] name=print key and value, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@272efa94, value = [B@7a6bf6f5), properties=Map(print.key -> true, print.value -> true), expected=someKey someValue PASSED DefaultMessageFormatterTest > [17] name=print fields in the beginning, middle and the end, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@64b45b73, value = [B@414dc54e), properties=Map(print.key -> true, print.value -> true, print.partition -> true), expected=Partition:9 someKey someValue STARTED DefaultMessageFormatterTest > [17] name=print fields in the beginning, middle and the end, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@64b45b73, value = [B@414dc54e), properties=Map(print.key -> true, print.value -> true, print.partition -> true), expected=Partition:9 someKey someValue PASSED DefaultMessageFormatterTest > [18] name=null value without custom null literal, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@7583c366, value = null), properties=Map(print.key -> true), expected=someKey null STARTED DefaultMessageFormatterTest > [18] name=null value without custom null literal, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@7583c366, value = null), properties=Map(print.key -> true), expected=someKey null PASSED DefaultMessageFormatterTest > [19] name=null value with custom null literal, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@36b7a7f5, value = null), properties=Map(print.key -> true, null.literal -> NULL), expected=someKey NULL STARTED DefaultMessageFormatterTest > [19] name=null value with custom null literal, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@36b7a7f5, value = null), properties=Map(print.key -> true, null.literal -> NULL), expected=someKey NULL PASSED 3398 tests completed, 1 failed, 7 skipped > Task :core:test FAILED FAILURE: Build failed with an exception. * What went wrong: Execution failed for task ':core:test'. > There were failing tests. See the report at: > file://<https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk8/ws/core/build/reports/tests/test/index.html> * Try: Run with --stacktrace option to get the stack trace. Run with --info or --debug option to get more log output. Run with --scan to get full insights. * Get more help at https://help.gradle.org Deprecated Gradle features were used in this build, making it incompatible with Gradle 7.0. Use '--warning-mode all' to show the individual deprecation warnings. See https://docs.gradle.org/6.8.1/userguide/command_line_interface.html#sec:command_line_warnings BUILD FAILED in 1h 28m 2s 250 actionable tasks: 214 executed, 36 up-to-date Build step 'Execute shell' marked build as failure Recording test results Not sending mail to unregistered user git...@hugo-hirsch.de
