See <https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk15/672/display/redirect?page=changes>
Changes: [github] MINOR: update Streams upgrade notes with removed APIs (#10420) [github] MINOR: fix the wrong/missing anchor in docs caused link error (#10413) ------------------------------------------ [...truncated 3.68 MB...] 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@c944f39, value = [B@a66495a), 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@c944f39, value = [B@a66495a), 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@7b08ccea, value = [B@fdf56f4), 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@7b08ccea, value = [B@fdf56f4), 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@245a7c06, value = [B@51c7e68f), 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@245a7c06, value = [B@51c7e68f), 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@11f638b3, value = [B@4c41d458), 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@11f638b3, value = [B@4c41d458), 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@3b0c2b9a, value = [B@551151ea), 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@3b0c2b9a, value = [B@551151ea), 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@514b486a, value = [B@7f4be57d), 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@514b486a, value = [B@7f4be57d), 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@5e22ae3a, 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@5e22ae3a, 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@2ccb50ec, 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@2ccb50ec, value = null), properties=Map(print.key -> true, null.literal -> NULL), expected=someKey NULL PASSED TransactionsWithMaxInFlightOneTest > testTransactionalProducerSingleBrokerMaxInFlightOne() STARTED AclAuthorizerTest > testAuthorizeByResourceTypeMultipleAddAndRemove() PASSED AclAuthorizerTest > testThrowsOnAddPrefixedAclIfInterBrokerProtocolVersionTooLow() STARTED AclAuthorizerTest > testThrowsOnAddPrefixedAclIfInterBrokerProtocolVersionTooLow() PASSED AclAuthorizerTest > testAccessAllowedIfAllowAclExistsOnPrefixedResource() STARTED AclAuthorizerTest > testAccessAllowedIfAllowAclExistsOnPrefixedResource() PASSED AclAuthorizerTest > testAuthorizeByResourceTypeDenyTakesPrecedence() STARTED AclAuthorizerTest > testAuthorizeByResourceTypeDenyTakesPrecedence() PASSED AclAuthorizerTest > testHighConcurrencyModificationOfResourceAcls() STARTED AclAuthorizerTest > testHighConcurrencyModificationOfResourceAcls() PASSED AclAuthorizerTest > testAuthorizeByResourceTypeWithAllPrincipalAce() STARTED AclAuthorizerTest > testAuthorizeByResourceTypeWithAllPrincipalAce() PASSED AclAuthorizerTest > testAuthorizeWithEmptyResourceName() STARTED AclAuthorizerTest > testAuthorizeWithEmptyResourceName() PASSED AclAuthorizerTest > testAuthorizeThrowsOnNonLiteralResource() STARTED TransactionsWithMaxInFlightOneTest > testTransactionalProducerSingleBrokerMaxInFlightOne() PASSED AclAuthorizerTest > testAuthorizeThrowsOnNonLiteralResource() PASSED AclAuthorizerTest > testDeleteAllAclOnPrefixedResource() STARTED AclAuthorizerTest > testDeleteAllAclOnPrefixedResource() PASSED AclAuthorizerTest > testAddAclsOnLiteralResource() STARTED AclAuthorizerTest > testAddAclsOnLiteralResource() PASSED AclAuthorizerTest > testGetAclsPrincipal() STARTED AclAuthorizerTest > testGetAclsPrincipal() PASSED AclAuthorizerTest > testWritesExtendedAclChangeEventIfInterBrokerProtocolNotSet() STARTED AclAuthorizerTest > testWritesExtendedAclChangeEventIfInterBrokerProtocolNotSet() PASSED AclAuthorizerTest > testAccessAllowedIfAllowAclExistsOnWildcardResource() STARTED AclAuthorizerTest > testAccessAllowedIfAllowAclExistsOnWildcardResource() PASSED AclAuthorizerTest > testLoadCache() STARTED AclAuthorizerTest > testLoadCache() PASSED AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypeWithAllHostAce() STARTED AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypeWithAllHostAce() PASSED AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypeIsolationUnrelatedDenyWontDominateAllow() STARTED AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypeIsolationUnrelatedDenyWontDominateAllow() PASSED AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypeWildcardResourceDenyDominate() STARTED AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypeWildcardResourceDenyDominate() PASSED AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypeWithAllOperationAce() STARTED AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypeWithAllOperationAce() PASSED AuthorizerInterfaceDefaultTest > testAuthorzeByResourceTypeSuperUserHasAccess() STARTED AuthorizerInterfaceDefaultTest > testAuthorzeByResourceTypeSuperUserHasAccess() PASSED AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypePrefixedResourceDenyDominate() STARTED AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypePrefixedResourceDenyDominate() PASSED AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypeMultipleAddAndRemove() STARTED AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypeMultipleAddAndRemove() PASSED AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypeDenyTakesPrecedence() STARTED AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypeDenyTakesPrecedence() PASSED AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypeWithAllPrincipalAce() STARTED AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypeWithAllPrincipalAce() PASSED AclEntryTest > testAclJsonConversion() STARTED AclEntryTest > testAclJsonConversion() PASSED AuthorizerWrapperTest > testAuthorizeByResourceTypeDisableAllowEveryoneOverride() STARTED AuthorizerWrapperTest > testAuthorizeByResourceTypeDisableAllowEveryoneOverride() PASSED AuthorizerWrapperTest > testAuthorizeByResourceTypeWithAllHostAce() STARTED AuthorizerWrapperTest > testAuthorizeByResourceTypeWithAllHostAce() PASSED AuthorizerWrapperTest > testAuthorizeByResourceTypeIsolationUnrelatedDenyWontDominateAllow() STARTED AuthorizerWrapperTest > testAuthorizeByResourceTypeIsolationUnrelatedDenyWontDominateAllow() PASSED AuthorizerWrapperTest > testAuthorizeByResourceTypeWildcardResourceDenyDominate() STARTED AuthorizerWrapperTest > testAuthorizeByResourceTypeWildcardResourceDenyDominate() PASSED AuthorizerWrapperTest > testAuthorizeByResourceTypeEnableAllowEveryOne() STARTED AuthorizerWrapperTest > testAuthorizeByResourceTypeEnableAllowEveryOne() PASSED AuthorizerWrapperTest > testAuthorizeByResourceTypeWithAllOperationAce() STARTED AuthorizerWrapperTest > testAuthorizeByResourceTypeWithAllOperationAce() PASSED AuthorizerWrapperTest > testAuthorzeByResourceTypeSuperUserHasAccess() STARTED AuthorizerWrapperTest > testAuthorzeByResourceTypeSuperUserHasAccess() PASSED AuthorizerWrapperTest > testAuthorizeByResourceTypePrefixedResourceDenyDominate() STARTED AuthorizerWrapperTest > testAuthorizeByResourceTypePrefixedResourceDenyDominate() PASSED AuthorizerWrapperTest > testAuthorizeByResourceTypeMultipleAddAndRemove() STARTED AuthorizerWrapperTest > testAuthorizeByResourceTypeMultipleAddAndRemove() PASSED AuthorizerWrapperTest > testAuthorizeByResourceTypeDenyTakesPrecedence() STARTED AuthorizerWrapperTest > testAuthorizeByResourceTypeDenyTakesPrecedence() PASSED AuthorizerWrapperTest > testAuthorizeByResourceTypeWithAllPrincipalAce() STARTED AuthorizerWrapperTest > testAuthorizeByResourceTypeWithAllPrincipalAce() 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 3496 tests completed, 2 failed, 7 skipped > Task :core:test FAILED FAILURE: Build failed with an exception. * What went wrong: Execution failed for task ':core:test'. > There were failing tests. See the report at: > file://<https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk15/ws/core/build/reports/tests/test/index.html> * Try: Run with --stacktrace option to get the stack trace. Run with --info or --debug option to get more log output. Run with --scan to get full insights. * Get more help at https://help.gradle.org Deprecated Gradle features were used in this build, making it incompatible with Gradle 7.0. Use '--warning-mode all' to show the individual deprecation warnings. See https://docs.gradle.org/6.8.3/userguide/command_line_interface.html#sec:command_line_warnings BUILD FAILED in 1h 19m 49s 257 actionable tasks: 220 executed, 37 up-to-date Build step 'Execute shell' marked build as failure Recording test results [Checks API] No suitable checks publisher found. Not sending mail to unregistered user git...@hugo-hirsch.de