See 
<https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk15/476/display/redirect?page=changes>

Changes:

[github] KAFKA-12236; New meta.properties logic for KIP-500 (#9967)


------------------------------------------
[...truncated 3.58 MB...]

ZooKeeperClientTest > testPipelinedGetData() PASSED

ZooKeeperClientTest > testZNodeChildChangeHandlerForChildChange() STARTED

ZooKeeperClientTest > testZNodeChildChangeHandlerForChildChange() PASSED

ZooKeeperClientTest > testGetChildrenExistingZNodeWithChildren() STARTED

ZooKeeperClientTest > testGetChildrenExistingZNodeWithChildren() PASSED

ZooKeeperClientTest > testSetDataExistingZNode() STARTED

ZooKeeperClientTest > testSetDataExistingZNode() PASSED

ZooKeeperClientTest > testZNodeChildChangeHandlerForChildChangeNotTriggered() 
STARTED

ZooKeeperClientTest > testZNodeChildChangeHandlerForChildChangeNotTriggered() 
PASSED

ZooKeeperClientTest > testMixedPipeline() STARTED

ZooKeeperClientTest > testMixedPipeline() PASSED

ZooKeeperClientTest > testGetDataExistingZNode() STARTED

ZooKeeperClientTest > testGetDataExistingZNode() PASSED

ZooKeeperClientTest > testDeleteExistingZNode() STARTED

ZooKeeperClientTest > testDeleteExistingZNode() PASSED

ZooKeeperClientTest > testSessionExpiry() STARTED

ZooKeeperClientTest > testSessionExpiry() PASSED

ZooKeeperClientTest > testSetDataNonExistentZNode() STARTED

ZooKeeperClientTest > testSetDataNonExistentZNode() PASSED

ZooKeeperClientTest > testConnectionViaNettyClient() STARTED

ZooKeeperClientTest > testConnectionViaNettyClient() PASSED

ZooKeeperClientTest > testDeleteNonExistentZNode() STARTED

ZooKeeperClientTest > testDeleteNonExistentZNode() PASSED

ZooKeeperClientTest > testExistsExistingZNode() STARTED

ZooKeeperClientTest > testExistsExistingZNode() PASSED

ZooKeeperClientTest > testZooKeeperStateChangeRateMetrics() STARTED

ZooKeeperClientTest > testZooKeeperStateChangeRateMetrics() PASSED

ZooKeeperClientTest > testZNodeChangeHandlerForDeletion() STARTED

ZooKeeperClientTest > testZNodeChangeHandlerForDeletion() PASSED

ZooKeeperClientTest > testGetAclNonExistentZNode() STARTED

ZooKeeperClientTest > testGetAclNonExistentZNode() PASSED

ZooKeeperClientTest > testStateChangeHandlerForAuthFailure() STARTED

ZooKeeperClientTest > testStateChangeHandlerForAuthFailure() PASSED

ResourceTypeTest > testJavaConversions() STARTED

ResourceTypeTest > testJavaConversions() PASSED

ResourceTypeTest > testFromString() STARTED

ResourceTypeTest > testFromString() PASSED

OperationTest > testJavaConversions() STARTED

OperationTest > testJavaConversions() PASSED

DelegationTokenManagerTest > testPeriodicTokenExpiry() STARTED

DelegationTokenManagerTest > testPeriodicTokenExpiry() PASSED

DelegationTokenManagerTest > testTokenRequestsWithDelegationTokenDisabled() 
STARTED

DelegationTokenManagerTest > testTokenRequestsWithDelegationTokenDisabled() 
PASSED

DelegationTokenManagerTest > testDescribeToken() STARTED

DelegationTokenManagerTest > testDescribeToken() PASSED

DelegationTokenManagerTest > testCreateToken() STARTED

DelegationTokenManagerTest > testCreateToken() PASSED

DelegationTokenManagerTest > testExpireToken() STARTED

DelegationTokenManagerTest > testExpireToken() PASSED

DelegationTokenManagerTest > testRenewToken() STARTED

DelegationTokenManagerTest > testRenewToken() PASSED

DelegationTokenManagerTest > testRemoveTokenHmac() STARTED

DelegationTokenManagerTest > testRemoveTokenHmac() PASSED

AclAuthorizerWithZkSaslTest > testAclUpdateWithSessionExpiration() STARTED

AclAuthorizerWithZkSaslTest > testAclUpdateWithSessionExpiration() PASSED

AclAuthorizerWithZkSaslTest > testAclUpdateWithAuthFailure() STARTED

AclAuthorizerWithZkSaslTest > testAclUpdateWithAuthFailure() 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@5be2d170, value = [B@1a693eb6), 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@5be2d170, value = [B@1a693eb6), 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@279c6a0b, value = [B@c00cd55), 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@279c6a0b, value = [B@c00cd55), 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@4bacc494, value = [B@2781533a), 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@4bacc494, value = [B@2781533a), 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@6309b9f3, value = [B@69e9aaa2), 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@6309b9f3, value = [B@69e9aaa2), 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@44cc4b6f, value = [B@6979c84f), 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@44cc4b6f, value = [B@6979c84f), 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@471122b2, value = [B@63893c48), 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@471122b2, value = [B@63893c48), 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@45b88465, value = [B@6224072d), 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@45b88465, value = [B@6224072d), 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@2c6ead69, value = [B@6afafd0), 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@2c6ead69, value = [B@6afafd0), 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@7b598cc, value = [B@456afa78), 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@7b598cc, value = [B@456afa78), 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@671cff30, value = [B@4c4468e7), 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@671cff30, value = [B@4c4468e7), 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@5eeff22d, value = [B@72e71773), 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@5eeff22d, value = [B@72e71773), 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@72029360, value = [B@1deede97), 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@72029360, value = [B@1deede97), 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@3c31399d, value = [B@76a7fde7), 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@3c31399d, value = [B@76a7fde7), 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@4e61a413, value = [B@76030fd), 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@4e61a413, value = [B@76030fd), 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@5021cf28, value = [B@678602c1), 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@5021cf28, value = [B@678602c1), 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@2404731e, value = [B@226558bb), 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@2404731e, value = [B@226558bb), 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@44ce978b, value = [B@4f11ed23), 
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@44ce978b, value = [B@4f11ed23), 
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@1bdd08cb, 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@1bdd08cb, 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@6ddb7c3, 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@6ddb7c3, value = null), properties=Map(print.key -> true, null.literal 
-> NULL), expected=someKey        NULL
 PASSED

TransactionsWithMaxInFlightOneTest > 
testTransactionalProducerSingleBrokerMaxInFlightOne() STARTED

TransactionsWithMaxInFlightOneTest > 
testTransactionalProducerSingleBrokerMaxInFlightOne() PASSED

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':tools:test'.
> There were failing tests. See the report at: 
> file://<https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk15/ws/tools/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 25m 3s
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