See <https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk11/454/display/redirect?page=changes>
Changes: [github] KAFKA-10604: Fix Streams default state.dir (#9420) ------------------------------------------ [...truncated 3.57 MB...] ControllerChannelManagerTest > testLeaderAndIsrRequestIsNew() PASSED ControllerChannelManagerTest > testStopReplicaRequestsWhileTopicQueuedForDeletion() STARTED ControllerChannelManagerTest > testStopReplicaRequestsWhileTopicQueuedForDeletion() PASSED ControllerChannelManagerTest > testLeaderAndIsrRequestSentToLiveOrShuttingDownBrokers() STARTED ControllerChannelManagerTest > testLeaderAndIsrRequestSentToLiveOrShuttingDownBrokers() PASSED ControllerChannelManagerTest > testStopReplicaInterBrokerProtocolVersion() STARTED ControllerChannelManagerTest > testStopReplicaInterBrokerProtocolVersion() PASSED ControllerChannelManagerTest > testStopReplicaSentOnlyToLiveAndShuttingDownBrokers() STARTED ControllerChannelManagerTest > testStopReplicaSentOnlyToLiveAndShuttingDownBrokers() PASSED ControllerChannelManagerTest > testStopReplicaGroupsByBroker() STARTED ControllerChannelManagerTest > testStopReplicaGroupsByBroker() PASSED ControllerChannelManagerTest > testUpdateMetadataDoesNotIncludePartitionsWithoutLeaderAndIsr() STARTED ControllerChannelManagerTest > testUpdateMetadataDoesNotIncludePartitionsWithoutLeaderAndIsr() PASSED ControllerChannelManagerTest > testMixedDeleteAndNotDeleteStopReplicaRequests() STARTED ControllerChannelManagerTest > testMixedDeleteAndNotDeleteStopReplicaRequests() PASSED ControllerChannelManagerTest > testLeaderAndIsrInterBrokerProtocolVersion() STARTED ControllerChannelManagerTest > testLeaderAndIsrInterBrokerProtocolVersion() PASSED ControllerChannelManagerTest > testUpdateMetadataRequestSent() STARTED ControllerChannelManagerTest > testUpdateMetadataRequestSent() PASSED ControllerChannelManagerTest > testUpdateMetadataRequestDuringTopicDeletion() STARTED ControllerChannelManagerTest > testUpdateMetadataRequestDuringTopicDeletion() PASSED ControllerChannelManagerTest > testUpdateMetadataIncludesLiveOrShuttingDownBrokers() STARTED ControllerChannelManagerTest > testUpdateMetadataIncludesLiveOrShuttingDownBrokers() PASSED ControllerChannelManagerTest > testStopReplicaRequestSent() STARTED ControllerChannelManagerTest > testStopReplicaRequestSent() PASSED ControllerChannelManagerTest > testStopReplicaRequestsWhileTopicDeletionStarted() STARTED ControllerChannelManagerTest > testStopReplicaRequestsWhileTopicDeletionStarted() PASSED ControllerChannelManagerTest > testLeaderAndIsrRequestSent() STARTED ControllerChannelManagerTest > testLeaderAndIsrRequestSent() PASSED ControllerChannelManagerTest > testStopReplicaRequestWithoutDeletePartitionWhileTopicDeletionStarted() STARTED ControllerChannelManagerTest > testStopReplicaRequestWithoutDeletePartitionWhileTopicDeletionStarted() PASSED FeatureZNodeTest > testDecodeFailOnInvalidFeatures() STARTED FeatureZNodeTest > testDecodeFailOnInvalidFeatures() PASSED FeatureZNodeTest > testEncodeDecode() STARTED FeatureZNodeTest > testEncodeDecode() PASSED FeatureZNodeTest > testDecodeSuccess() STARTED FeatureZNodeTest > testDecodeSuccess() PASSED FeatureZNodeTest > testDecodeFailOnInvalidVersionAndStatus() STARTED FeatureZNodeTest > testDecodeFailOnInvalidVersionAndStatus() PASSED ExtendedAclStoreTest > shouldHaveCorrectPaths() STARTED ExtendedAclStoreTest > shouldHaveCorrectPaths() PASSED ExtendedAclStoreTest > shouldRoundTripChangeNode() STARTED ExtendedAclStoreTest > shouldRoundTripChangeNode() PASSED ExtendedAclStoreTest > shouldThrowFromEncodeOnLiteral() STARTED ExtendedAclStoreTest > shouldThrowFromEncodeOnLiteral() PASSED ExtendedAclStoreTest > shouldThrowIfConstructedWithLiteral() STARTED ExtendedAclStoreTest > shouldThrowIfConstructedWithLiteral() PASSED ExtendedAclStoreTest > shouldWriteChangesToTheWritePath() STARTED ExtendedAclStoreTest > shouldWriteChangesToTheWritePath() PASSED ExtendedAclStoreTest > shouldHaveCorrectPatternType() STARTED ExtendedAclStoreTest > shouldHaveCorrectPatternType() 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@28442429, value = [B@38cca792), 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@28442429, value = [B@38cca792), 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@3e057afe, value = [B@63a8ba9b), 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@3e057afe, value = [B@63a8ba9b), 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@2c8dafa7, value = [B@5032aca5), 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@2c8dafa7, value = [B@5032aca5), 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@45f5fed7, value = [B@63afe890), 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@45f5fed7, value = [B@63afe890), 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@221e83d5, value = [B@678c54b7), 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@221e83d5, value = [B@678c54b7), 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@d650dd7, value = [B@11928f83), 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@d650dd7, value = [B@11928f83), 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@4744a64f, value = [B@42e87bfc), 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@4744a64f, value = [B@42e87bfc), 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@67c6cdc3, value = [B@62adb82f), 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@67c6cdc3, value = [B@62adb82f), 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@390ceb, value = [B@10fa08b), 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@390ceb, value = [B@10fa08b), 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@5f157b4d, value = [B@17836a10), 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@5f157b4d, value = [B@17836a10), 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@6bf49b93, value = [B@d09b06c), 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@6bf49b93, value = [B@d09b06c), 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@79b27d93, value = [B@756d5b5f), 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@79b27d93, value = [B@756d5b5f), 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@3a8a6e62, value = [B@7ac0338f), 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@3a8a6e62, value = [B@7ac0338f), 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@664c17a4, value = [B@1deb0ca9), 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@664c17a4, value = [B@1deb0ca9), 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@2996c92a, value = [B@422b03d2), 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@2996c92a, value = [B@422b03d2), 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@44dccd04, value = [B@1970f72), 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@44dccd04, value = [B@1970f72), 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@3b0788fb, value = [B@785fb8cf), 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@3b0788fb, value = [B@785fb8cf), 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@2b4aa48f, 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@2b4aa48f, 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@6aa1a9fa, 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@6aa1a9fa, value = null), properties=Map(print.key -> true, null.literal -> NULL), expected=someKey NULL PASSED 3214 tests completed, 1 failed, 7 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:mirror:test'. > There were failing tests. See the report at: > file://<https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk11/ws/connect/mirror/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'. > There were failing tests. See the report at: > file://<https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk11/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 34m 40s 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
