See <https://ci-builds.apache.org/job/Kafka/job/kafka-2.8-jdk8/17/display/redirect?page=changes>
Changes: [Rajini Sivaram] MINOR: Remove unused LeaderAndIsrResponse.partitions() since it has been replaced with partitionErrors() (#10127) ------------------------------------------ [...truncated 7.05 MB...] PartitionLeaderElectionAlgorithmsTest > testPreferredReplicaPartitionLeaderElection() STARTED PartitionLeaderElectionAlgorithmsTest > testPreferredReplicaPartitionLeaderElection() PASSED PartitionLeaderElectionAlgorithmsTest > testReassignPartitionLeaderElectionWithEmptyIsr() STARTED PartitionLeaderElectionAlgorithmsTest > testReassignPartitionLeaderElectionWithEmptyIsr() PASSED PartitionLeaderElectionAlgorithmsTest > testControlledShutdownPartitionLeaderElectionAllIsrSimultaneouslyShutdown() STARTED PartitionLeaderElectionAlgorithmsTest > testControlledShutdownPartitionLeaderElectionAllIsrSimultaneouslyShutdown() PASSED PartitionLeaderElectionAlgorithmsTest > testOfflinePartitionLeaderElectionLastIsrOfflineUncleanLeaderElectionEnabled() STARTED PartitionLeaderElectionAlgorithmsTest > testOfflinePartitionLeaderElectionLastIsrOfflineUncleanLeaderElectionEnabled() PASSED PartitionLeaderElectionAlgorithmsTest > testPreferredReplicaPartitionLeaderElectionPreferredReplicaNotInIsrNotLive() STARTED PartitionLeaderElectionAlgorithmsTest > testPreferredReplicaPartitionLeaderElectionPreferredReplicaNotInIsrNotLive() PASSED PartitionLeaderElectionAlgorithmsTest > testOfflinePartitionLeaderElectionLastIsrOfflineUncleanLeaderElectionDisabled() STARTED PartitionLeaderElectionAlgorithmsTest > testOfflinePartitionLeaderElectionLastIsrOfflineUncleanLeaderElectionDisabled() PASSED TopicDeletionManagerTest > testBrokerFailureAfterDeletionStarted() STARTED TopicDeletionManagerTest > testBrokerFailureAfterDeletionStarted() PASSED TopicDeletionManagerTest > testInitialization() STARTED TopicDeletionManagerTest > testInitialization() PASSED TopicDeletionManagerTest > testBasicDeletion() STARTED TopicDeletionManagerTest > testBasicDeletion() PASSED TopicDeletionManagerTest > testDeletionWithBrokerOffline() STARTED TopicDeletionManagerTest > testDeletionWithBrokerOffline() PASSED ControllerFailoverTest > testHandleIllegalStateException() STARTED ControllerFailoverTest > testHandleIllegalStateException() PASSED ZkNodeChangeNotificationListenerTest > testProcessNotification() STARTED ZkNodeChangeNotificationListenerTest > testProcessNotification() PASSED ZkNodeChangeNotificationListenerTest > testSwallowsProcessorException() STARTED ZkNodeChangeNotificationListenerTest > testSwallowsProcessorException() PASSED InterBrokerSendThreadTest > shouldCreateClientRequestAndSendWhenNodeIsReady() STARTED InterBrokerSendThreadTest > shouldCreateClientRequestAndSendWhenNodeIsReady() PASSED InterBrokerSendThreadTest > testFailingExpiredRequests() STARTED InterBrokerSendThreadTest > testFailingExpiredRequests() PASSED InterBrokerSendThreadTest > shouldCallCompletionHandlerWithDisconnectedResponseWhenNodeNotReady() STARTED InterBrokerSendThreadTest > shouldCallCompletionHandlerWithDisconnectedResponseWhenNodeNotReady() PASSED InterBrokerSendThreadTest > shouldNotSendAnythingWhenNoRequests() STARTED InterBrokerSendThreadTest > shouldNotSendAnythingWhenNoRequests() PASSED KafkaNetworkChannelTest > testWakeupClientOnSend() STARTED KafkaNetworkChannelTest > testWakeupClientOnSend() PASSED KafkaNetworkChannelTest > testSendToBlackedOutDestination() STARTED KafkaNetworkChannelTest > testSendToBlackedOutDestination() PASSED KafkaNetworkChannelTest > testSendAndFailAuthentication() STARTED KafkaNetworkChannelTest > testSendAndFailAuthentication() PASSED KafkaNetworkChannelTest > testSendAndReceiveOutboundRequest() STARTED KafkaNetworkChannelTest > testSendAndReceiveOutboundRequest() PASSED KafkaNetworkChannelTest > testSendAndDisconnect() STARTED KafkaNetworkChannelTest > testSendAndDisconnect() PASSED KafkaNetworkChannelTest > testSendToUnknownDestination() STARTED KafkaNetworkChannelTest > testSendToUnknownDestination() PASSED RaftManagerTest > testShutdownIoThread() STARTED RaftManagerTest > testShutdownIoThread() PASSED RaftManagerTest > testUncaughtExceptionInIoThread() STARTED RaftManagerTest > testUncaughtExceptionInIoThread() 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@47b0684c, value = [B@747db78), 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@47b0684c, value = [B@747db78), 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@29cbb0b9, value = [B@106e22e3), 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@29cbb0b9, value = [B@106e22e3), 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@4f8f8ff4, value = [B@48cf1610), 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@4f8f8ff4, value = [B@48cf1610), 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@3c7539c8, value = [B@5ded7d9f), 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@3c7539c8, value = [B@5ded7d9f), 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@6e2eb9f9, value = [B@5ee14dba), 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@6e2eb9f9, value = [B@5ee14dba), 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@4bcf84d7, value = [B@7d7819b4), 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@4bcf84d7, value = [B@7d7819b4), 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@66028693, value = [B@32da8b74), 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@66028693, value = [B@32da8b74), 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@58448c4, value = [B@388c4479), 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@58448c4, value = [B@388c4479), 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@4a487be5, value = [B@2cafd8f3), 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@4a487be5, value = [B@2cafd8f3), 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@58a18bc7, value = [B@a9bb860), 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@58a18bc7, value = [B@a9bb860), 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@52377ade, value = [B@7989102b), properties=HashMap(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@52377ade, value = [B@7989102b), properties=HashMap(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@2da2436e, value = [B@7aada602), properties=HashMap(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@2da2436e, value = [B@7aada602), properties=HashMap(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@1325c203, value = [B@229c8004), 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@1325c203, value = [B@229c8004), 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@a90261d, value = [B@3798d896), 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@a90261d, value = [B@3798d896), 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@7142f2c1, value = [B@3ce548ad), 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@7142f2c1, value = [B@3ce548ad), 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@374e31e2, value = [B@466313f5), 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@374e31e2, value = [B@466313f5), 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@7060578a, value = [B@2e421ec8), 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@7060578a, value = [B@2e421ec8), 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@7924737, 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@7924737, 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@c72a5c9, 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@c72a5c9, value = null), properties=Map(print.key -> true, null.literal -> NULL), expected=someKey NULL PASSED TransactionsTest > testFailureToFenceEpoch() SKIPPED > Task :core:test FAILED FAILURE: Build completed with 2 failures. 1: Task failed with an exception. ----------- * What went wrong: Execution failed for task ':connect:runtime:test'. > There were failing tests. See the report at: > file://<https://ci-builds.apache.org/job/Kafka/job/kafka-2.8-jdk8/ws/connect/runtime/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. ============================================================================== 2: Task failed with an exception. ----------- * What went wrong: Execution failed for task ':core:test'. > Process 'Gradle Test Executor 69' finished with non-zero exit value 1 This problem might be caused by incorrect test process configuration. Please refer to the test execution section in the User Manual at https://docs.gradle.org/6.8.1/userguide/java_testing.html#sec:test_execution * 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 20m 0s 250 actionable tasks: 243 executed, 7 up-to-date Build step 'Execute shell' marked build as failure Recording test results
