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

Changes:

[github] KAFKA-12245; Fix flaky `FetcherTest.testEarlierOffsetResetArrivesLate` 
(#10006)


------------------------------------------
[...truncated 7.15 MB...]

TimerTest > testTaskExpiration() STARTED

TimerTest > testTaskExpiration() PASSED

ReplicationUtilsTest > testUpdateLeaderAndIsr() STARTED

ReplicationUtilsTest > testUpdateLeaderAndIsr() PASSED

KafkaMetadataLogTest > testFailToIncreaseLogStartPastHighWatermark() STARTED

KafkaMetadataLogTest > testFailToIncreaseLogStartPastHighWatermark() PASSED

KafkaMetadataLogTest > testCreateReplicatedLogTruncatesFully() STARTED

KafkaMetadataLogTest > testCreateReplicatedLogTruncatesFully() PASSED

KafkaMetadataLogTest > testCreateSnapshot() STARTED

KafkaMetadataLogTest > testCreateSnapshot() PASSED

KafkaMetadataLogTest > testUpdateLogStartOffset() STARTED

KafkaMetadataLogTest > testUpdateLogStartOffset() PASSED

KafkaMetadataLogTest > testCleanupSnapshots() STARTED

KafkaMetadataLogTest > testCleanupSnapshots() PASSED

KafkaMetadataLogTest > testTruncateFullyToLatestSnapshot() STARTED

KafkaMetadataLogTest > testTruncateFullyToLatestSnapshot() PASSED

KafkaMetadataLogTest > testDoesntTruncateFully() STARTED

KafkaMetadataLogTest > testDoesntTruncateFully() PASSED

KafkaMetadataLogTest > testUpdateLogStartOffsetWithMissingSnapshot() STARTED

KafkaMetadataLogTest > testUpdateLogStartOffsetWithMissingSnapshot() PASSED

KafkaMetadataLogTest > testReadMissingSnapshot() STARTED

KafkaMetadataLogTest > testReadMissingSnapshot() PASSED

RaftManagerTest > testShutdownIoThread() STARTED

RaftManagerTest > testShutdownIoThread() PASSED

RaftManagerTest > testUncaughtExceptionInIoThread() STARTED

RaftManagerTest > testUncaughtExceptionInIoThread() PASSED

RequestChannelTest > testNonAlterRequestsNotTransformed() STARTED

RequestChannelTest > testNonAlterRequestsNotTransformed() PASSED

RequestChannelTest > testAlterRequests() STARTED

RequestChannelTest > testAlterRequests() PASSED

RequestChannelTest > testJsonRequests() STARTED

RequestChannelTest > testJsonRequests() PASSED

RequestChannelTest > testIncrementalAlterRequests() STARTED

RequestChannelTest > testIncrementalAlterRequests() 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

TransactionsWithMaxInFlightOneTest > 
testTransactionalProducerSingleBrokerMaxInFlightOne() STARTED

TransactionsWithMaxInFlightOneTest > 
testTransactionalProducerSingleBrokerMaxInFlightOne() PASSED

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@4e111231, value = [B@34d9bf7d), 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@4e111231, value = [B@34d9bf7d), 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@166258e3, value = [B@6f393f05), 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@166258e3, value = [B@6f393f05), 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@7d67a3a2, value = [B@f73f26a), 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@7d67a3a2, value = [B@f73f26a), 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@b520627, value = [B@2db5d15f), 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@b520627, value = [B@2db5d15f), 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@6d0f1df8, value = [B@7dff4291), 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@6d0f1df8, value = [B@7dff4291), 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@66070037, value = [B@65bb1a81), 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@66070037, value = [B@65bb1a81), 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@70ce3b13, value = [B@77221451), 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@70ce3b13, value = [B@77221451), 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@297aa43a, value = [B@1428dc86), 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@297aa43a, value = [B@1428dc86), 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@153f6bb3, value = [B@72d875d9), 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@153f6bb3, value = [B@72d875d9), 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@326defb5, value = [B@3aa229c), 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@326defb5, value = [B@3aa229c), 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@7707df11, value = [B@201a26b5), 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@7707df11, value = [B@201a26b5), 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@7d577544, value = [B@2f3b06b0), 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@7d577544, value = [B@2f3b06b0), 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@660dbb11, value = [B@17d316eb), 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@660dbb11, value = [B@17d316eb), 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@51e8ac00, value = [B@26912e0b), 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@51e8ac00, value = [B@26912e0b), 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@2d4fccfb, value = [B@2224e3f7), 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@2d4fccfb, value = [B@2224e3f7), 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@36b8c31f, value = [B@19f652b5), 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@36b8c31f, value = [B@19f652b5), 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@356c2154, value = [B@62ac6cac), 
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@356c2154, value = [B@62ac6cac), 
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@415e7f6c, 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@415e7f6c, 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@d7ed367, 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@d7ed367, value = null), properties=Map(print.key -> true, null.literal 
-> NULL), expected=someKey        NULL
 PASSED

3255 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-jdk11/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 33m 19s
250 actionable tasks: 243 executed, 7 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