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

Changes:

[Boyang Chen] KAFKA-12381: remove live broker checks for forwarding topic 
creation (#10240)


------------------------------------------
[...truncated 7.23 MB...]
SocketServerTest > remoteCloseWithIncompleteBufferedReceive() STARTED

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

DynamicConnectionQuotaTest > testDynamicConnectionQuota() STARTED

DynamicConnectionQuotaTest > testDynamicConnectionQuota() PASSED

DynamicConnectionQuotaTest > testDynamicListenerConnectionQuota() STARTED

DynamicConnectionQuotaTest > testDynamicListenerConnectionQuota() PASSED

DynamicConnectionQuotaTest > testDynamicListenerConnectionCreationRateQuota() 
STARTED

DynamicConnectionQuotaTest > testDynamicListenerConnectionCreationRateQuota() 
PASSED

DynamicConnectionQuotaTest > testDynamicIpConnectionRateQuota() STARTED

DynamicConnectionQuotaTest > testDynamicIpConnectionRateQuota() 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@59b4f6c2, value = [B@22c47ea4), 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@59b4f6c2, value = [B@22c47ea4), 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@186f7d6c, value = [B@19df119b), 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@186f7d6c, value = [B@19df119b), 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@f3e483b, value = [B@75fba313), 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@f3e483b, value = [B@75fba313), 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@161c34dd, value = [B@772eac4c), 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@161c34dd, value = [B@772eac4c), 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@aac4d02, value = [B@22e7847f), 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@aac4d02, value = [B@22e7847f), 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@55aae622, value = [B@57e47c17), 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@55aae622, value = [B@57e47c17), 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@3fc8ffb4, value = [B@2112404e), 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@3fc8ffb4, value = [B@2112404e), 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@230b29b8, value = [B@57fbfd0a), 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@230b29b8, value = [B@57fbfd0a), 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@2fb69d1e, value = [B@1c15b896), 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@2fb69d1e, value = [B@1c15b896), 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@75f79882, value = [B@44174fa2), 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@75f79882, value = [B@44174fa2), 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@6ab2e049, value = [B@114a6026), properties=HashMap(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@6ab2e049, value = [B@114a6026), properties=HashMap(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@58b0d905, value = [B@2624f7ee), properties=HashMap(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@58b0d905, value = [B@2624f7ee), properties=HashMap(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@5b69ebcb, value = [B@1960ebd0), 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@5b69ebcb, value = [B@1960ebd0), 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@47467108, value = [B@46dc7589), 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@47467108, value = [B@46dc7589), 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@527fe92a, value = [B@4cdfb6de), 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@527fe92a, value = [B@4cdfb6de), 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@38e5507c, value = [B@1db01ad4), 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@38e5507c, value = [B@1db01ad4), 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@1307698e, value = [B@efca780), 
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@1307698e, value = [B@efca780), 
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@628c24b0, 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@628c24b0, 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@7e98ff42, 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@7e98ff42, value = null), properties=Map(print.key -> true, 
null.literal -> NULL), expected=someKey       NULL
 PASSED

3413 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 21m 19s
257 actionable tasks: 250 executed, 7 up-to-date
Build step 'Execute shell' marked build as failure
Recording test results

Reply via email to