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

Changes:

[github] KAFKA-12352: Make sure all rejoin group and reset state has a reason 
(#10232)


------------------------------------------
[...truncated 3.67 MB...]
BrokerCompressionTest > [11] messageCompression=none, brokerCompression=lz4 
PASSED

BrokerCompressionTest > [12] messageCompression=gzip, brokerCompression=lz4 
STARTED

BrokerCompressionTest > [12] messageCompression=gzip, brokerCompression=lz4 
PASSED

BrokerCompressionTest > [13] messageCompression=snappy, brokerCompression=lz4 
STARTED

BrokerCompressionTest > [13] messageCompression=snappy, brokerCompression=lz4 
PASSED

BrokerCompressionTest > [14] messageCompression=lz4, brokerCompression=lz4 
STARTED

BrokerCompressionTest > [14] messageCompression=lz4, brokerCompression=lz4 
PASSED

BrokerCompressionTest > [15] messageCompression=zstd, brokerCompression=lz4 
STARTED

BrokerCompressionTest > [15] messageCompression=zstd, brokerCompression=lz4 
PASSED

BrokerCompressionTest > [16] messageCompression=none, brokerCompression=snappy 
STARTED

BrokerCompressionTest > [16] messageCompression=none, brokerCompression=snappy 
PASSED

BrokerCompressionTest > [17] messageCompression=gzip, brokerCompression=snappy 
STARTED

BrokerCompressionTest > [17] messageCompression=gzip, brokerCompression=snappy 
PASSED

BrokerCompressionTest > [18] messageCompression=snappy, 
brokerCompression=snappy STARTED

BrokerCompressionTest > [18] messageCompression=snappy, 
brokerCompression=snappy PASSED

BrokerCompressionTest > [19] messageCompression=lz4, brokerCompression=snappy 
STARTED

BrokerCompressionTest > [19] messageCompression=lz4, brokerCompression=snappy 
PASSED

BrokerCompressionTest > [20] messageCompression=zstd, brokerCompression=snappy 
STARTED

BrokerCompressionTest > [20] messageCompression=zstd, brokerCompression=snappy 
PASSED

BrokerCompressionTest > [21] messageCompression=none, brokerCompression=gzip 
STARTED

BrokerCompressionTest > [21] messageCompression=none, brokerCompression=gzip 
PASSED

BrokerCompressionTest > [22] messageCompression=gzip, brokerCompression=gzip 
STARTED

BrokerCompressionTest > [22] messageCompression=gzip, brokerCompression=gzip 
PASSED

BrokerCompressionTest > [23] messageCompression=snappy, brokerCompression=gzip 
STARTED

BrokerCompressionTest > [23] messageCompression=snappy, brokerCompression=gzip 
PASSED

BrokerCompressionTest > [24] messageCompression=lz4, brokerCompression=gzip 
STARTED

BrokerCompressionTest > [24] messageCompression=lz4, brokerCompression=gzip 
PASSED

BrokerCompressionTest > [25] messageCompression=zstd, brokerCompression=gzip 
STARTED

BrokerCompressionTest > [25] messageCompression=zstd, brokerCompression=gzip 
PASSED

BrokerCompressionTest > [26] messageCompression=none, 
brokerCompression=producer STARTED

BrokerCompressionTest > [26] messageCompression=none, 
brokerCompression=producer PASSED

BrokerCompressionTest > [27] messageCompression=gzip, 
brokerCompression=producer STARTED

BrokerCompressionTest > [27] messageCompression=gzip, 
brokerCompression=producer PASSED

BrokerCompressionTest > [28] messageCompression=snappy, 
brokerCompression=producer STARTED

BrokerCompressionTest > [28] messageCompression=snappy, 
brokerCompression=producer PASSED

BrokerCompressionTest > [29] messageCompression=lz4, brokerCompression=producer 
STARTED

BrokerCompressionTest > [29] messageCompression=lz4, brokerCompression=producer 
PASSED

BrokerCompressionTest > [30] messageCompression=zstd, 
brokerCompression=producer STARTED

BrokerCompressionTest > [30] messageCompression=zstd, 
brokerCompression=producer 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@286d9e3d, value = [B@690faba), 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@286d9e3d, value = [B@690faba), 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@6316102f, value = [B@62d263dd), 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@6316102f, value = [B@62d263dd), 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@23d61e05, value = [B@733c3664), 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@23d61e05, value = [B@733c3664), 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@20f8c744, value = [B@51c5840d), 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@20f8c744, value = [B@51c5840d), 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@42708e06, value = [B@506d1f3a), 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@42708e06, value = [B@506d1f3a), 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@36492094, value = [B@4b512fbc), 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@36492094, value = [B@4b512fbc), 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@d97886e, value = [B@35bbd229), 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@d97886e, value = [B@35bbd229), 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@4a89098a, value = [B@8e7f3a8), 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@4a89098a, value = [B@8e7f3a8), 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@3982ce22, value = [B@52c379a1), 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@3982ce22, value = [B@52c379a1), 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@67493c21, value = [B@48951d34), 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@67493c21, value = [B@48951d34), 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@1d26bf6, value = [B@76d82959), 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@1d26bf6, value = [B@76d82959), 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@585eab97, value = [B@38c27115), 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@585eab97, value = [B@38c27115), 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@2add2020, value = [B@1d7846c3), 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@2add2020, value = [B@1d7846c3), 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@1b36c12e, value = [B@58a92e48), 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@1b36c12e, value = [B@58a92e48), 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@7b825c0, value = [B@dc241db), 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@7b825c0, value = [B@dc241db), 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@20d0defc, value = [B@319a7fc0), 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@20d0defc, value = [B@319a7fc0), 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@da5f2ff, value = [B@29151e8f), 
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@da5f2ff, value = [B@29151e8f), 
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@23acdda4, 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@23acdda4, 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@7b526846, 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@7b526846, value = null), properties=Map(print.key -> true, 
null.literal -> NULL), expected=someKey       NULL
 PASSED

ControllerContextTest > 
testPartitionFullReplicaAssignmentReturnsEmptyAssignmentIfTopicOrPartitionDoesNotExist()
 STARTED

ControllerContextTest > 
testPartitionFullReplicaAssignmentReturnsEmptyAssignmentIfTopicOrPartitionDoesNotExist()
 PASSED

ControllerContextTest > 
testPartitionReplicaAssignmentForTopicReturnsEmptyMapIfTopicDoesNotExist() 
STARTED

ControllerContextTest > 
testPartitionReplicaAssignmentForTopicReturnsEmptyMapIfTopicDoesNotExist() 
PASSED

ControllerContextTest > testPreferredReplicaImbalanceMetric() STARTED

ControllerContextTest > testPreferredReplicaImbalanceMetric() PASSED

ControllerContextTest > 
testPartitionReplicaAssignmentForTopicReturnsExpectedReplicaAssignments() 
STARTED

ControllerContextTest > 
testPartitionReplicaAssignmentForTopicReturnsExpectedReplicaAssignments() PASSED

ControllerContextTest > testReassignTo() STARTED

ControllerContextTest > testReassignTo() PASSED

ControllerContextTest > testPartitionReplicaAssignment() STARTED

ControllerContextTest > testPartitionReplicaAssignment() PASSED

ControllerContextTest > 
testUpdatePartitionFullReplicaAssignmentUpdatesReplicaAssignment() STARTED

ControllerContextTest > 
testUpdatePartitionFullReplicaAssignmentUpdatesReplicaAssignment() PASSED

ControllerContextTest > testReassignToIdempotence() STARTED

ControllerContextTest > testReassignToIdempotence() PASSED

ControllerContextTest > 
testPartitionReplicaAssignmentReturnsEmptySeqIfTopicOrPartitionDoesNotExist() 
STARTED

ControllerContextTest > 
testPartitionReplicaAssignmentReturnsEmptySeqIfTopicOrPartitionDoesNotExist() 
PASSED

3476 tests completed, 1 failed, 7 skipped

> Task :core:test FAILED

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':core:test'.
> There were failing tests. See the report at: 
> file://<https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk15/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.3/userguide/command_line_interface.html#sec:command_line_warnings

BUILD FAILED in 57m 25s
257 actionable tasks: 220 executed, 37 up-to-date
Build step 'Execute shell' marked build as failure
Recording test results
[Checks API] No suitable checks publisher found.
Not sending mail to unregistered user git...@hugo-hirsch.de

Reply via email to