You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2021/02/06 23:11:49 UTC
Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #511
See <https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk15/511/display/redirect?page=changes>
Changes:
[github] KAFKA-9751: Forward CreateTopicsRequest for FindCoordinator/Metadata when topic creation is needed (#9579)
------------------------------------------
[...truncated 3.56 MB...]
ZooKeeperClientTest > testGetChildrenExistingZNodeWithChildren() PASSED
ZooKeeperClientTest > testSetDataExistingZNode() STARTED
ZooKeeperClientTest > testSetDataExistingZNode() PASSED
ZooKeeperClientTest > testZNodeChildChangeHandlerForChildChangeNotTriggered() STARTED
ZooKeeperClientTest > testZNodeChildChangeHandlerForChildChangeNotTriggered() PASSED
ZooKeeperClientTest > testMixedPipeline() STARTED
ZooKeeperClientTest > testMixedPipeline() PASSED
ZooKeeperClientTest > testGetDataExistingZNode() STARTED
ZooKeeperClientTest > testGetDataExistingZNode() PASSED
ZooKeeperClientTest > testDeleteExistingZNode() STARTED
ZooKeeperClientTest > testDeleteExistingZNode() PASSED
ZooKeeperClientTest > testSessionExpiry() STARTED
ZooKeeperClientTest > testSessionExpiry() PASSED
ZooKeeperClientTest > testSetDataNonExistentZNode() STARTED
ZooKeeperClientTest > testSetDataNonExistentZNode() PASSED
ZooKeeperClientTest > testConnectionViaNettyClient() STARTED
ZooKeeperClientTest > testConnectionViaNettyClient() PASSED
ZooKeeperClientTest > testDeleteNonExistentZNode() STARTED
ZooKeeperClientTest > testDeleteNonExistentZNode() PASSED
ZooKeeperClientTest > testExistsExistingZNode() STARTED
ZooKeeperClientTest > testExistsExistingZNode() PASSED
ZooKeeperClientTest > testZooKeeperStateChangeRateMetrics() STARTED
ZooKeeperClientTest > testZooKeeperStateChangeRateMetrics() PASSED
ZooKeeperClientTest > testZNodeChangeHandlerForDeletion() STARTED
ZooKeeperClientTest > testZNodeChangeHandlerForDeletion() PASSED
ZooKeeperClientTest > testGetAclNonExistentZNode() STARTED
ZooKeeperClientTest > testGetAclNonExistentZNode() PASSED
ZooKeeperClientTest > testStateChangeHandlerForAuthFailure() STARTED
ZooKeeperClientTest > testStateChangeHandlerForAuthFailure() PASSED
ResourceTypeTest > testJavaConversions() STARTED
ResourceTypeTest > testJavaConversions() PASSED
ResourceTypeTest > testFromString() STARTED
ResourceTypeTest > testFromString() PASSED
OperationTest > testJavaConversions() STARTED
OperationTest > testJavaConversions() PASSED
DelegationTokenManagerTest > testPeriodicTokenExpiry() STARTED
DelegationTokenManagerTest > testPeriodicTokenExpiry() PASSED
DelegationTokenManagerTest > testTokenRequestsWithDelegationTokenDisabled() STARTED
DelegationTokenManagerTest > testTokenRequestsWithDelegationTokenDisabled() PASSED
DelegationTokenManagerTest > testDescribeToken() STARTED
DelegationTokenManagerTest > testDescribeToken() PASSED
DelegationTokenManagerTest > testCreateToken() STARTED
DelegationTokenManagerTest > testCreateToken() PASSED
DelegationTokenManagerTest > testExpireToken() STARTED
DelegationTokenManagerTest > testExpireToken() PASSED
DelegationTokenManagerTest > testRenewToken() STARTED
DelegationTokenManagerTest > testRenewToken() PASSED
DelegationTokenManagerTest > testRemoveTokenHmac() STARTED
DelegationTokenManagerTest > testRemoveTokenHmac() PASSED
AclAuthorizerWithZkSaslTest > testAclUpdateWithSessionExpiration() STARTED
AclAuthorizerWithZkSaslTest > testAclUpdateWithSessionExpiration() PASSED
AclAuthorizerWithZkSaslTest > testAclUpdateWithAuthFailure() STARTED
AclAuthorizerWithZkSaslTest > testAclUpdateWithAuthFailure() PASSED
DefaultMessageFormatterTest > [1] name=print nothing, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@3daf346e, value = [B@7e23f7a8), 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@3daf346e, value = [B@7e23f7a8), 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@22001dea, value = [B@437f20b5), 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@22001dea, value = [B@437f20b5), 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@2e93988e, value = [B@ab70cd4), 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@2e93988e, value = [B@ab70cd4), 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@28faaf25, value = [B@123a4807), 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@28faaf25, value = [B@123a4807), 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@20dff526, value = [B@12bc9c45), 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@20dff526, value = [B@12bc9c45), 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@6f429ab0, value = [B@2ff89d2f), 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@6f429ab0, value = [B@2ff89d2f), 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@70d13b33, value = [B@679cfd8), 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@70d13b33, value = [B@679cfd8), 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@7d9542bd, value = [B@16efb9c5), 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@7d9542bd, value = [B@16efb9c5), 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@6f9e1088, value = [B@275115ac), 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@6f9e1088, value = [B@275115ac), 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@6a07af65, value = [B@159ceb9d), 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@6a07af65, value = [B@159ceb9d), 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@5f7aa9e6, value = [B@26367218), 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@5f7aa9e6, value = [B@26367218), 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@719d8d3c, value = [B@32f5091), 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@719d8d3c, value = [B@32f5091), 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@990ec8b, value = [B@1ca3f913), 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@990ec8b, value = [B@1ca3f913), 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@781810b6, value = [B@76625f8a), 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@781810b6, value = [B@76625f8a), 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@758a4b34, value = [B@278c5290), 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@758a4b34, value = [B@278c5290), 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@1fa97b77, value = [B@7bd3e907), 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@1fa97b77, value = [B@7bd3e907), 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@4b9367da, value = [B@25b40f3), 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@4b9367da, value = [B@25b40f3), 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@2a402682, 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@2a402682, 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@1c219ab6, 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@1c219ab6, value = null), properties=Map(print.key -> true, null.literal -> NULL), expected=someKey NULL
PASSED
TransactionsWithMaxInFlightOneTest > testTransactionalProducerSingleBrokerMaxInFlightOne() STARTED
TransactionsWithMaxInFlightOneTest > testTransactionalProducerSingleBrokerMaxInFlightOne() PASSED
TransactionsTest > testReadCommittedConsumerShouldNotSeeUndecidedData() SKIPPED
3043 tests completed, 1 failed, 8 skipped
> Task :core:test FAILED
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':core:test'.
> Process 'Gradle Test Executor 77' finished with non-zero exit value 1
This problem might be caused by incorrect test process configuration.
Please refer to the test execution section in the User Manual at https://docs.gradle.org/6.8.1/userguide/java_testing.html#sec:test_execution
* 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 18m 8s
251 actionable tasks: 215 executed, 36 up-to-date
Build step 'Execute shell' marked build as failure
Recording test results
Not sending mail to unregistered user github@hugo-hirsch.de
Jenkins build is back to normal : Kafka » kafka-trunk-jdk15 #514
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk15/514/display/redirect?page=changes>
Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #513
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk15/513/display/redirect?page=changes>
Changes:
[github] MINOR: StopReplicaResp and StopReplicaReq Test should cover all available version (#10068)
------------------------------------------
[...truncated 3.62 MB...]
LinuxIoMetricsCollectorTest > testUnableToReadNonexistentProcFile() STARTED
LinuxIoMetricsCollectorTest > testUnableToReadNonexistentProcFile() PASSED
AssignmentStateTest > [1] isr=List(101, 102, 103), replicas=List(101, 102, 103), adding=List(), removing=List(), original=List(), isUnderReplicated=false STARTED
AssignmentStateTest > [1] isr=List(101, 102, 103), replicas=List(101, 102, 103), adding=List(), removing=List(), original=List(), isUnderReplicated=false PASSED
AssignmentStateTest > [2] isr=List(101, 102), replicas=List(101, 102, 103), adding=List(), removing=List(), original=List(), isUnderReplicated=true STARTED
AssignmentStateTest > [2] isr=List(101, 102), replicas=List(101, 102, 103), adding=List(), removing=List(), original=List(), isUnderReplicated=true PASSED
AssignmentStateTest > [3] isr=List(101, 102, 103), replicas=List(101, 102, 103), adding=List(104, 105), removing=List(102), original=List(101, 102, 103), isUnderReplicated=false STARTED
AssignmentStateTest > [3] isr=List(101, 102, 103), replicas=List(101, 102, 103), adding=List(104, 105), removing=List(102), original=List(101, 102, 103), isUnderReplicated=false PASSED
AssignmentStateTest > [4] isr=List(101, 102, 103), replicas=List(101, 102, 103), adding=List(104, 105), removing=List(), original=List(101, 102, 103), isUnderReplicated=false STARTED
AssignmentStateTest > [4] isr=List(101, 102, 103), replicas=List(101, 102, 103), adding=List(104, 105), removing=List(), original=List(101, 102, 103), isUnderReplicated=false PASSED
AssignmentStateTest > [5] isr=List(101, 102, 103), replicas=List(101, 102, 103), adding=List(), removing=List(102), original=List(101, 102, 103), isUnderReplicated=false STARTED
AssignmentStateTest > [5] isr=List(101, 102, 103), replicas=List(101, 102, 103), adding=List(), removing=List(102), original=List(101, 102, 103), isUnderReplicated=false PASSED
AssignmentStateTest > [6] isr=List(102, 103), replicas=List(102, 103), adding=List(101), removing=List(), original=List(102, 103), isUnderReplicated=false STARTED
AssignmentStateTest > [6] isr=List(102, 103), replicas=List(102, 103), adding=List(101), removing=List(), original=List(102, 103), isUnderReplicated=false PASSED
AssignmentStateTest > [7] isr=List(103, 104, 105), replicas=List(101, 102, 103), adding=List(104, 105, 106), removing=List(), original=List(101, 102, 103), isUnderReplicated=false STARTED
AssignmentStateTest > [7] isr=List(103, 104, 105), replicas=List(101, 102, 103), adding=List(104, 105, 106), removing=List(), original=List(101, 102, 103), isUnderReplicated=false PASSED
AssignmentStateTest > [8] isr=List(103, 104, 105), replicas=List(101, 102, 103), adding=List(104, 105, 106), removing=List(), original=List(101, 102, 103), isUnderReplicated=false STARTED
AssignmentStateTest > [8] isr=List(103, 104, 105), replicas=List(101, 102, 103), adding=List(104, 105, 106), removing=List(), original=List(101, 102, 103), isUnderReplicated=false PASSED
AssignmentStateTest > [9] isr=List(103, 104), replicas=List(101, 102, 103), adding=List(104, 105, 106), removing=List(), original=List(101, 102, 103), isUnderReplicated=true STARTED
AssignmentStateTest > [9] isr=List(103, 104), replicas=List(101, 102, 103), adding=List(104, 105, 106), removing=List(), original=List(101, 102, 103), isUnderReplicated=true PASSED
PartitionTest > testMakeLeaderDoesNotUpdateEpochCacheForOldFormats() STARTED
PartitionTest > testMakeLeaderDoesNotUpdateEpochCacheForOldFormats() PASSED
PartitionTest > testIsrExpansion() STARTED
PartitionTest > testIsrExpansion() PASSED
PartitionTest > testReadRecordEpochValidationForLeader() STARTED
PartitionTest > testReadRecordEpochValidationForLeader() PASSED
PartitionTest > testAlterIsrUnknownTopic() STARTED
PartitionTest > testAlterIsrUnknownTopic() PASSED
PartitionTest > testIsrNotShrunkIfUpdateFails() STARTED
PartitionTest > testIsrNotShrunkIfUpdateFails() PASSED
PartitionTest > testFetchOffsetForTimestampEpochValidationForFollower() STARTED
PartitionTest > testFetchOffsetForTimestampEpochValidationForFollower() PASSED
PartitionTest > testIsrNotExpandedIfUpdateFails() STARTED
PartitionTest > testIsrNotExpandedIfUpdateFails() PASSED
PartitionTest > testLogConfigDirtyAsBrokerUpdated() STARTED
PartitionTest > testLogConfigDirtyAsBrokerUpdated() PASSED
PartitionTest > testAddAndRemoveMetrics() STARTED
PartitionTest > testAddAndRemoveMetrics() PASSED
PartitionTest > testListOffsetIsolationLevels() STARTED
PartitionTest > testListOffsetIsolationLevels() PASSED
PartitionTest > testAppendRecordsAsFollowerBelowLogStartOffset() STARTED
PartitionTest > testAppendRecordsAsFollowerBelowLogStartOffset() PASSED
PartitionTest > testFetchLatestOffsetIncludesLeaderEpoch() STARTED
PartitionTest > testFetchLatestOffsetIncludesLeaderEpoch() PASSED
PartitionTest > testUnderReplicatedPartitionsCorrectSemantics() STARTED
PartitionTest > testUnderReplicatedPartitionsCorrectSemantics() PASSED
PartitionTest > testFetchOffsetSnapshotEpochValidationForFollower() STARTED
PartitionTest > testFetchOffsetSnapshotEpochValidationForFollower() PASSED
PartitionTest > testMaybeShrinkIsr() STARTED
PartitionTest > testMaybeShrinkIsr() PASSED
PartitionTest > testLogConfigNotDirty() STARTED
PartitionTest > testLogConfigNotDirty() PASSED
PartitionTest > testMonotonicOffsetsAfterLeaderChange() STARTED
PartitionTest > testMonotonicOffsetsAfterLeaderChange() PASSED
PartitionTest > testUpdateAssignmentAndIsr() STARTED
PartitionTest > testUpdateAssignmentAndIsr() PASSED
PartitionTest > testMakeFollowerWithNoLeaderIdChange() STARTED
PartitionTest > testMakeFollowerWithNoLeaderIdChange() PASSED
PartitionTest > testAppendRecordsToFollowerWithNoReplicaThrowsException() STARTED
PartitionTest > testAppendRecordsToFollowerWithNoReplicaThrowsException() PASSED
PartitionTest > testFollowerDoesNotJoinISRUntilCaughtUpToOffsetWithinCurrentLeaderEpoch() STARTED
PartitionTest > testFollowerDoesNotJoinISRUntilCaughtUpToOffsetWithinCurrentLeaderEpoch() PASSED
PartitionTest > testSingleInFlightAlterIsr() STARTED
PartitionTest > testSingleInFlightAlterIsr() PASSED
PartitionTest > testShouldNotShrinkIsrIfFollowerCaughtUpToLogEnd() STARTED
PartitionTest > testShouldNotShrinkIsrIfFollowerCaughtUpToLogEnd() PASSED
PartitionTest > testFetchOffsetSnapshotEpochValidationForLeader() STARTED
PartitionTest > testFetchOffsetSnapshotEpochValidationForLeader() PASSED
PartitionTest > testOffsetForLeaderEpochValidationForLeader() STARTED
PartitionTest > testOffsetForLeaderEpochValidationForLeader() PASSED
PartitionTest > testAtMinIsr() STARTED
PartitionTest > testAtMinIsr() PASSED
PartitionTest > testAlterIsrInvalidVersion() STARTED
PartitionTest > testAlterIsrInvalidVersion() PASSED
PartitionTest > testOffsetForLeaderEpochValidationForFollower() STARTED
PartitionTest > testOffsetForLeaderEpochValidationForFollower() PASSED
PartitionTest > testMakeLeaderUpdatesEpochCache() STARTED
PartitionTest > testMakeLeaderUpdatesEpochCache() PASSED
PartitionTest > testUseCheckpointToInitializeHighWatermark() STARTED
PartitionTest > testUseCheckpointToInitializeHighWatermark() PASSED
PartitionTest > testMaybeReplaceCurrentWithFutureReplicaDifferentBaseOffsets() STARTED
PartitionTest > testMaybeReplaceCurrentWithFutureReplicaDifferentBaseOffsets() PASSED
PartitionTest > testFetchOffsetForTimestampEpochValidationForLeader() STARTED
PartitionTest > testFetchOffsetForTimestampEpochValidationForLeader() PASSED
PartitionTest > testMakeFollowerWithWithFollowerAppendRecords() STARTED
PartitionTest > testMakeFollowerWithWithFollowerAppendRecords() PASSED
PartitionTest > testShouldNotShrinkIsrIfPreviousFetchIsCaughtUp() STARTED
PartitionTest > testShouldNotShrinkIsrIfPreviousFetchIsCaughtUp() PASSED
PartitionTest > testGetReplica() STARTED
PartitionTest > testGetReplica() PASSED
PartitionTest > testReadRecordEpochValidationForFollower() STARTED
PartitionTest > testReadRecordEpochValidationForFollower() PASSED
PartitionTest > testAlterIsrUnexpectedError() STARTED
PartitionTest > testAlterIsrUnexpectedError() PASSED
PartitionTest > testZkIsrManagerAsyncCallback() STARTED
PartitionTest > testZkIsrManagerAsyncCallback() PASSED
PartitionTest > testLogConfigDirtyAsTopicUpdated() STARTED
PartitionTest > testLogConfigDirtyAsTopicUpdated() PASSED
PartitionTest > testMaybeReplaceCurrentWithFutureReplica() STARTED
PartitionTest > testMaybeReplaceCurrentWithFutureReplica() PASSED
PartitionTest > testLastFetchedOffsetValidation() STARTED
PartitionTest > testLastFetchedOffsetValidation() PASSED
PartitionTest > testUpdateFollowerFetchState() STARTED
PartitionTest > testUpdateFollowerFetchState() PASSED
TransactionsWithMaxInFlightOneTest > testTransactionalProducerSingleBrokerMaxInFlightOne() STARTED
TransactionsWithMaxInFlightOneTest > testTransactionalProducerSingleBrokerMaxInFlightOne() PASSED
3325 tests completed, 1 failed, 7 skipped
> Task :core:test FAILED
FAILURE: Build completed with 2 failures.
1: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task ':streams:test'.
> There were failing tests. See the report at: file://<https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk15/ws/streams/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.
==============================================================================
2: Task 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.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 1h 46m 43s
251 actionable tasks: 215 executed, 36 up-to-date
Build step 'Execute shell' marked build as failure
Recording test results
Not sending mail to unregistered user github@hugo-hirsch.de
Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #512
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk15/512/display/redirect?page=changes>
Changes:
[John Roesler] bump to 2.9 development version
------------------------------------------
[...truncated 3.45 MB...]
ZooKeeperClientTest > testSessionExpiry() STARTED
ZooKeeperClientTest > testSessionExpiry() PASSED
ZooKeeperClientTest > testSetDataNonExistentZNode() STARTED
ZooKeeperClientTest > testSetDataNonExistentZNode() PASSED
ZooKeeperClientTest > testConnectionViaNettyClient() STARTED
ZooKeeperClientTest > testConnectionViaNettyClient() PASSED
ZooKeeperClientTest > testDeleteNonExistentZNode() STARTED
ZooKeeperClientTest > testDeleteNonExistentZNode() PASSED
ZooKeeperClientTest > testExistsExistingZNode() STARTED
ZooKeeperClientTest > testExistsExistingZNode() PASSED
ZooKeeperClientTest > testZooKeeperStateChangeRateMetrics() STARTED
ZooKeeperClientTest > testZooKeeperStateChangeRateMetrics() PASSED
ZooKeeperClientTest > testZNodeChangeHandlerForDeletion() STARTED
ZooKeeperClientTest > testZNodeChangeHandlerForDeletion() PASSED
ZooKeeperClientTest > testGetAclNonExistentZNode() STARTED
ZooKeeperClientTest > testGetAclNonExistentZNode() PASSED
ZooKeeperClientTest > testStateChangeHandlerForAuthFailure() STARTED
ZooKeeperClientTest > testStateChangeHandlerForAuthFailure() PASSED
ResourceTypeTest > testJavaConversions() STARTED
ResourceTypeTest > testJavaConversions() PASSED
ResourceTypeTest > testFromString() STARTED
ResourceTypeTest > testFromString() PASSED
OperationTest > testJavaConversions() STARTED
OperationTest > testJavaConversions() PASSED
DelegationTokenManagerTest > testPeriodicTokenExpiry() STARTED
DelegationTokenManagerTest > testPeriodicTokenExpiry() PASSED
DelegationTokenManagerTest > testTokenRequestsWithDelegationTokenDisabled() STARTED
DelegationTokenManagerTest > testTokenRequestsWithDelegationTokenDisabled() PASSED
DelegationTokenManagerTest > testDescribeToken() STARTED
DelegationTokenManagerTest > testDescribeToken() PASSED
DelegationTokenManagerTest > testCreateToken() STARTED
DelegationTokenManagerTest > testCreateToken() PASSED
DelegationTokenManagerTest > testExpireToken() STARTED
DelegationTokenManagerTest > testExpireToken() PASSED
DelegationTokenManagerTest > testRenewToken() STARTED
DelegationTokenManagerTest > testRenewToken() PASSED
DelegationTokenManagerTest > testRemoveTokenHmac() STARTED
DelegationTokenManagerTest > testRemoveTokenHmac() PASSED
AclAuthorizerWithZkSaslTest > testAclUpdateWithSessionExpiration() STARTED
AclAuthorizerWithZkSaslTest > testAclUpdateWithSessionExpiration() PASSED
AclAuthorizerWithZkSaslTest > testAclUpdateWithAuthFailure() STARTED
AclAuthorizerWithZkSaslTest > testAclUpdateWithAuthFailure() PASSED
DefaultMessageFormatterTest > [1] name=print nothing, record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = [118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), key = [B@51777392, value = [B@12ce5687), 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@51777392, value = [B@12ce5687), 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@4eee68f9, value = [B@2ef465cd), 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@4eee68f9, value = [B@2ef465cd), 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@42360a93, value = [B@1da6110c), 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@42360a93, value = [B@1da6110c), 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@20b20be1, value = [B@2d65d837), 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@20b20be1, value = [B@2d65d837), 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@5f752d9a, value = [B@72f67909), 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@5f752d9a, value = [B@72f67909), 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@42ab89b5, value = [B@410c45b7), 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@42ab89b5, value = [B@410c45b7), 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@37e3a9f1, value = [B@769cb035), 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@37e3a9f1, value = [B@769cb035), 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@68646972, value = [B@4b66a834), 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@68646972, value = [B@4b66a834), 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@61603c88, value = [B@726e3589), 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@61603c88, value = [B@726e3589), 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@4a78ef0a, value = [B@1358cac2), 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@4a78ef0a, value = [B@1358cac2), 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@d5b9030, value = [B@1d4f6bab), 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@d5b9030, value = [B@1d4f6bab), 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@1042d7b7, value = [B@459901a7), 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@1042d7b7, value = [B@459901a7), 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@1412d334, value = [B@7266e02e), 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@1412d334, value = [B@7266e02e), 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@7906ddb7, value = [B@7b8f3ad0), 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@7906ddb7, value = [B@7b8f3ad0), 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@3e2dd21f, value = [B@31c881de), 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@3e2dd21f, value = [B@31c881de), 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@7eec0935, value = [B@7c37f582), 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@7eec0935, value = [B@7c37f582), 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@7b46e064, value = [B@6cc099fe), 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@7b46e064, value = [B@6cc099fe), 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@3d4663ea, 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@3d4663ea, 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@6cacf14d, 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@6cacf14d, value = null), properties=Map(print.key -> true, null.literal -> NULL), expected=someKey NULL
PASSED
TransactionsWithMaxInFlightOneTest > testTransactionalProducerSingleBrokerMaxInFlightOne() STARTED
TransactionsWithMaxInFlightOneTest > testTransactionalProducerSingleBrokerMaxInFlightOne() PASSED
ServerGenerateBrokerIdTest > testBrokerMetadataOnIdCollision() SKIPPED
2122 tests completed, 1 failed, 8 skipped
> Task :core:test FAILED
FAILURE: Build completed with 3 failures.
1: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task ':connect:mirror:test'.
> There were failing tests. See the report at: file://<https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk15/ws/connect/mirror/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.
==============================================================================
2: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task ':connect:runtime:test'.
> There were failing tests. See the report at: file://<https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk15/ws/connect/runtime/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.
==============================================================================
3: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task ':core:test'.
> Process 'Gradle Test Executor 77' finished with non-zero exit value 1
This problem might be caused by incorrect test process configuration.
Please refer to the test execution section in the User Manual at https://docs.gradle.org/6.8.1/userguide/java_testing.html#sec:test_execution
* 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 29m 12s
251 actionable tasks: 215 executed, 36 up-to-date
Build step 'Execute shell' marked build as failure
Recording test results
Not sending mail to unregistered user github@hugo-hirsch.de