See 
<https://ci-builds.apache.org/job/Kafka/job/kafka-2.8-jdk8/65/display/redirect?page=changes>

Changes:

[A. Sophie Blee-Goldman] HOTFIX: timeout issue in removeStreamThread() (#10321)


------------------------------------------
[...truncated 3.60 MB...]

SocketServerTest > remoteCloseWithIncompleteBufferedReceive() PASSED

SocketServerTest > testStagedListenerShutdownWhenConnectionQueueIsFull() STARTED

SocketServerTest > testStagedListenerShutdownWhenConnectionQueueIsFull() PASSED

SocketServerTest > testStagedListenerStartup() STARTED

SocketServerTest > testStagedListenerStartup() PASSED

SocketServerTest > testConnectionRateLimit() STARTED

SocketServerTest > testConnectionRateLimit() PASSED

SocketServerTest > testConnectionRatePerIp() STARTED

SocketServerTest > testConnectionRatePerIp() PASSED

SocketServerTest > processCompletedSendException() STARTED

SocketServerTest > processCompletedSendException() PASSED

SocketServerTest > processDisconnectedException() STARTED

SocketServerTest > processDisconnectedException() PASSED

SocketServerTest > closingChannelWithBufferedReceives() STARTED

SocketServerTest > closingChannelWithBufferedReceives() PASSED

SocketServerTest > sendCancelledKeyException() STARTED

SocketServerTest > sendCancelledKeyException() PASSED

SocketServerTest > processCompletedReceiveException() STARTED

SocketServerTest > processCompletedReceiveException() PASSED

SocketServerTest > testControlPlaneAsPrivilegedListener() STARTED

SocketServerTest > testControlPlaneAsPrivilegedListener() PASSED

SocketServerTest > closingChannelSendFailure() STARTED

SocketServerTest > closingChannelSendFailure() PASSED

SocketServerTest > idleExpiryWithBufferedReceives() STARTED

SocketServerTest > idleExpiryWithBufferedReceives() PASSED

SocketServerTest > testSocketsCloseOnShutdown() STARTED

SocketServerTest > testSocketsCloseOnShutdown() PASSED

SocketServerTest > 
testNoOpActionResponseWithThrottledChannelWhereThrottlingAlreadyDone() STARTED

SocketServerTest > 
testNoOpActionResponseWithThrottledChannelWhereThrottlingAlreadyDone() PASSED

SocketServerTest > pollException() STARTED

SocketServerTest > pollException() PASSED

SocketServerTest > closingChannelWithBufferedReceivesFailedSend() STARTED

SocketServerTest > closingChannelWithBufferedReceivesFailedSend() PASSED

SocketServerTest > remoteCloseWithBufferedReceives() STARTED

SocketServerTest > remoteCloseWithBufferedReceives() PASSED

SocketServerTest > testThrottledSocketsClosedOnShutdown() STARTED

SocketServerTest > testThrottledSocketsClosedOnShutdown() PASSED

SocketServerTest > closingChannelWithCompleteAndIncompleteBufferedReceives() 
STARTED

SocketServerTest > closingChannelWithCompleteAndIncompleteBufferedReceives() 
PASSED

SocketServerTest > testInterBrokerListenerAsPrivilegedListener() STARTED

SocketServerTest > testInterBrokerListenerAsPrivilegedListener() PASSED

SocketServerTest > testSslSocketServer() STARTED

SocketServerTest > testSslSocketServer() PASSED

SocketServerTest > testDisabledRequestIsRejected() STARTED

SocketServerTest > testDisabledRequestIsRejected() PASSED

SocketServerTest > tooBigRequestIsRejected() STARTED

SocketServerTest > tooBigRequestIsRejected() PASSED

SocketServerTest > 
testNoOpActionResponseWithThrottledChannelWhereThrottlingInProgress() STARTED

SocketServerTest > 
testNoOpActionResponseWithThrottledChannelWhereThrottlingInProgress() PASSED

KafkaTimerTest > testKafkaTimer() STARTED

KafkaTimerTest > testKafkaTimer() PASSED

LinuxIoMetricsCollectorTest > testReadProcFile() STARTED

LinuxIoMetricsCollectorTest > testReadProcFile() PASSED

LinuxIoMetricsCollectorTest > testUnableToReadNonexistentProcFile() STARTED

LinuxIoMetricsCollectorTest > testUnableToReadNonexistentProcFile() PASSED

TransactionsWithMaxInFlightOneTest > 
testTransactionalProducerSingleBrokerMaxInFlightOne() STARTED

TransactionsWithMaxInFlightOneTest > 
testTransactionalProducerSingleBrokerMaxInFlightOne() 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@685031d2, value = [B@5c15a0c0), 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@685031d2, value = [B@5c15a0c0), 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@99604af, value = [B@7874b6fd), 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@99604af, value = [B@7874b6fd), 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@16c2e240, value = [B@7db64877), 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@16c2e240, value = [B@7db64877), 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@44bc8812, value = [B@19220d26), 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@44bc8812, value = [B@19220d26), 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@18732ca0, value = [B@57492a29), 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@18732ca0, value = [B@57492a29), 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@7795d4ca, value = [B@7e57bc23), 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@7795d4ca, value = [B@7e57bc23), 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@7fc08965, value = [B@6146ecd6), 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@7fc08965, value = [B@6146ecd6), 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@382c57b0, value = [B@7b594232), 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@382c57b0, value = [B@7b594232), 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@29779d, value = [B@565f0b12), 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@29779d, value = [B@565f0b12), 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@769d4626, value = [B@25c5ff85), 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@769d4626, value = [B@25c5ff85), 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@4d950a07, value = [B@471c332a), 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@4d950a07, value = [B@471c332a), 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@5b2cf199, value = [B@511f14ae), 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@5b2cf199, value = [B@511f14ae), 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@34bfe9b8, value = [B@121c0966), 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@34bfe9b8, value = [B@121c0966), 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@2e809285, value = [B@793499f), 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@2e809285, value = [B@793499f), 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@4caa82fc, value = [B@3e0fe536), 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@4caa82fc, value = [B@3e0fe536), 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@14315cc8, value = [B@9f32060), 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@14315cc8, value = [B@9f32060), 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@4e784e4b, value = [B@5e9897c4), 
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@4e784e4b, value = [B@5e9897c4), 
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@789e5239, 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@789e5239, 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@248f5764, 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@248f5764, value = null), properties=Map(print.key -> true, 
null.literal -> NULL), expected=someKey       NULL
 PASSED

3417 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-2.8-jdk8/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 28m 17s
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.

Reply via email to