Unsubscribe

בתאריך שבת, 13 בפבר׳ 2021, 18:59, מאת Apache Jenkins Server ‏<
jenk...@builds.apache.org>:

> See <
> https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk11/514/display/redirect?page=changes
> >
>
> Changes:
>
> [github] MINOR: Update zstd and use classes with no finalizers (#10120)
>
>
> ------------------------------------------
> [...truncated 3.61 MB...]
>
> ControllerEventManagerTest > testSuccessfulEvent() PASSED
>
> ControllerEventManagerTest > testMetricsCleanedOnClose() STARTED
>
> ControllerEventManagerTest > testMetricsCleanedOnClose() PASSED
>
> ControllerChannelManagerTest >
> testStopReplicaRequestWithAlreadyDefinedDeletedPartition() STARTED
>
> ControllerChannelManagerTest >
> testStopReplicaRequestWithAlreadyDefinedDeletedPartition() PASSED
>
> ControllerChannelManagerTest >
> testUpdateMetadataInterBrokerProtocolVersion() STARTED
>
> ControllerChannelManagerTest >
> testUpdateMetadataInterBrokerProtocolVersion() PASSED
>
> ControllerChannelManagerTest > testLeaderAndIsrRequestIsNew() STARTED
>
> 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@77f9453a, value = [B@13b20fc8),
> 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@77f9453a, value = [B@13b20fc8),
> 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@5a23b1ac, value = [B@28e0b7e4), 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@5a23b1ac, value = [B@28e0b7e4), 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@d675b46, value = [B@5722109a), 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@d675b46, value = [B@5722109a), 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@10cb7503, value = [B@3db9af69),
> 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@10cb7503, value = [B@3db9af69),
> 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@ab36ef3, value = [B@4dd209ff),
> 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@ab36ef3, value = [B@4dd209ff),
> 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@67a1e2b, value = [B@76c83b6a),
> 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@67a1e2b, value = [B@76c83b6a),
> 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@679d07b6, value = [B@3a5d774b),
> 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@679d07b6, value = [B@3a5d774b),
> 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@6c00ad6d, value = [B@5b24d8ec),
> 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@6c00ad6d, value = [B@5b24d8ec),
> 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@548bc489, value = [B@53d067c),
> 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@548bc489, value = [B@53d067c),
> 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@670a66f4, value = [B@7940c04b), 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@670a66f4, value = [B@7940c04b), 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@448560a5, value = [B@b0e4032),
> 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@448560a5, value = [B@b0e4032),
> 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@3f07aa61, value = [B@403a6752),
> 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@3f07aa61, value = [B@403a6752),
> 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@2fd5b7b8, value = [B@56237da0),
> 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@2fd5b7b8, value = [B@56237da0),
> 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@458c6baf, value = [B@80fc0c3),
> 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@458c6baf, value = [B@80fc0c3),
> 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@708f90dc, value = [B@4f980dd),
> 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@708f90dc, value = [B@4f980dd),
> 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@228e42fe, value = [B@547187b4), 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@228e42fe, value = [B@547187b4), 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@6731353a, value = [B@6c38ab71),
> 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@6731353a, value = [B@6c38ab71),
> 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@7eabbe86, 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@7eabbe86, 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@174bd2c2, 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@174bd2c2, value = null),
> properties=Map(print.key -> true, null.literal -> NULL), expected=someKey
>      NULL
>  PASSED
>
> FAILURE: Build 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-trunk-jdk11/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.
>
> * 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 26m 44s
> 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
>

Reply via email to