Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #568

[Apache Jenkins Server]

See 


Changes:

[github] MINOR: bump release version to 3.0.0-SNAPSHOT (#10186)


--
[...truncated 7.35 MB...]
AclAuthorizerTest > testDeleteAclOnWildcardResource() PASSED

AclAuthorizerTest > testAuthorizerZkConfigFromKafkaConfig() STARTED

AclAuthorizerTest > testAuthorizerZkConfigFromKafkaConfig() PASSED

AclAuthorizerTest > testChangeListenerTiming() STARTED

AclAuthorizerTest > testChangeListenerTiming() PASSED

AclAuthorizerTest > 
testWritesLiteralWritesLiteralAclChangeEventWhenInterBrokerProtocolLessThanKafkaV2eralAclChangesForOlderProtocolVersions()
 STARTED

AclAuthorizerTest > 
testWritesLiteralWritesLiteralAclChangeEventWhenInterBrokerProtocolLessThanKafkaV2eralAclChangesForOlderProtocolVersions()
 PASSED

AclAuthorizerTest > testAuthorzeByResourceTypeSuperUserHasAccess() STARTED

AclAuthorizerTest > testAuthorzeByResourceTypeSuperUserHasAccess() PASSED

AclAuthorizerTest > testAuthorizeByResourceTypePrefixedResourceDenyDominate() 
STARTED

AclAuthorizerTest > testAuthorizeByResourceTypePrefixedResourceDenyDominate() 
PASSED

AclAuthorizerTest > testAuthorizeByResourceTypeMultipleAddAndRemove() 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

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 > 

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #541

[Apache Jenkins Server]

See 


Changes:

[github] MINOR: bump release version to 3.0.0-SNAPSHOT (#10186)


--
[...truncated 3.67 MB...]

SocketServerTest > testConnectionId() STARTED

SocketServerTest > testConnectionId() PASSED

SocketServerTest > remoteCloseSendFailure() STARTED

SocketServerTest > remoteCloseSendFailure() PASSED

SocketServerTest > testBrokerSendAfterChannelClosedUpdatesRequestMetrics() 
STARTED

SocketServerTest > testBrokerSendAfterChannelClosedUpdatesRequestMetrics() 
PASSED

SocketServerTest > 
testControlPlaneTakePrecedenceOverInterBrokerListenerAsPrivilegedListener() 
STARTED

SocketServerTest > 
testControlPlaneTakePrecedenceOverInterBrokerListenerAsPrivilegedListener() 
PASSED

SocketServerTest > testNoOpAction() STARTED

SocketServerTest > testNoOpAction() PASSED

SocketServerTest > simpleRequest() STARTED

SocketServerTest > simpleRequest() PASSED

SocketServerTest > 
testSendActionResponseWithThrottledChannelWhereThrottlingInProgress() STARTED

SocketServerTest > 
testSendActionResponseWithThrottledChannelWhereThrottlingInProgress() PASSED

SocketServerTest > testIdleConnection() STARTED

SocketServerTest > testIdleConnection() PASSED

SocketServerTest > remoteCloseWithoutBufferedReceives() STARTED

SocketServerTest > remoteCloseWithoutBufferedReceives() PASSED

SocketServerTest > remoteCloseWithCompleteAndIncompleteBufferedReceives() 
STARTED

SocketServerTest > remoteCloseWithCompleteAndIncompleteBufferedReceives() PASSED

SocketServerTest > testZeroMaxConnectionsPerIp() STARTED

SocketServerTest > testZeroMaxConnectionsPerIp() PASSED

SocketServerTest > testClientInformationWithLatestApiVersionsRequest() STARTED

SocketServerTest > testClientInformationWithLatestApiVersionsRequest() PASSED

SocketServerTest > testMetricCollectionAfterShutdown() STARTED

SocketServerTest > testMetricCollectionAfterShutdown() PASSED

SocketServerTest > testSessionPrincipal() STARTED

SocketServerTest > testSessionPrincipal() PASSED

SocketServerTest > configureNewConnectionException() STARTED

SocketServerTest > configureNewConnectionException() PASSED

SocketServerTest > testSaslReauthenticationFailureWithKip152SaslAuthenticate() 
STARTED

SocketServerTest > testSaslReauthenticationFailureWithKip152SaslAuthenticate() 
PASSED

SocketServerTest > testMaxConnectionsPerIpOverrides() STARTED

SocketServerTest > testMaxConnectionsPerIpOverrides() PASSED

SocketServerTest > processNewResponseException() STARTED

SocketServerTest > processNewResponseException() PASSED

SocketServerTest > remoteCloseWithIncompleteBufferedReceive() STARTED

SocketServerTest > remoteCloseWithIncompleteBufferedReceive() PASSED

SocketServerTest > testStagedListenerShutdownWhenConnectionQueueIsFull() STARTED

SocketServerTest > testStagedListenerShutdownWhenConnectionQueueIsFull() PASSED

SocketServerTest > testStagedListenerStartup() STARTED

SocketServerTest > testStagedListenerStartup() PASSED

SocketServerTest > testConnectionRateLimit() STARTED

SocketServerTest > testConnectionRateLimit() PASSED

SocketServerTest > testConnectionRatePerIp() STARTED

SocketServerTest > testConnectionRatePerIp() PASSED

SocketServerTest > processCompletedSendException() STARTED

SocketServerTest > processCompletedSendException() PASSED

SocketServerTest > processDisconnectedException() STARTED

SocketServerTest > processDisconnectedException() PASSED

SocketServerTest > closingChannelWithBufferedReceives() STARTED

SocketServerTest > closingChannelWithBufferedReceives() PASSED

SocketServerTest > sendCancelledKeyException() STARTED

SocketServerTest > sendCancelledKeyException() PASSED

SocketServerTest > processCompletedReceiveException() STARTED

SocketServerTest > processCompletedReceiveException() PASSED

SocketServerTest > testControlPlaneAsPrivilegedListener() STARTED

SocketServerTest > testControlPlaneAsPrivilegedListener() PASSED

SocketServerTest > closingChannelSendFailure() STARTED

SocketServerTest > closingChannelSendFailure() PASSED

SocketServerTest > idleExpiryWithBufferedReceives() STARTED

SocketServerTest > idleExpiryWithBufferedReceives() PASSED

SocketServerTest > testSocketsCloseOnShutdown() STARTED

SocketServerTest > testSocketsCloseOnShutdown() PASSED

SocketServerTest > 
testNoOpActionResponseWithThrottledChannelWhereThrottlingAlreadyDone() STARTED

SocketServerTest > 
testNoOpActionResponseWithThrottledChannelWhereThrottlingAlreadyDone() PASSED

SocketServerTest > pollException() STARTED

SocketServerTest > pollException() PASSED

SocketServerTest > closingChannelWithBufferedReceivesFailedSend() STARTED

SocketServerTest > closingChannelWithBufferedReceivesFailedSend() PASSED

SocketServerTest > remoteCloseWithBufferedReceives() STARTED

SocketServerTest > remoteCloseWithBufferedReceives() PASSED

SocketServerTest > testThrottledSocketsClosedOnShutdown() STARTED

SocketServerTest > 

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #510

[Apache Jenkins Server]

See 


Changes:

[github] MINOR: bump release version to 3.0.0-SNAPSHOT (#10186)


--
[...truncated 3.65 MB...]

TransactionsTest > testReadCommittedConsumerShouldNotSeeUndecidedData() STARTED

TransactionsTest > testReadCommittedConsumerShouldNotSeeUndecidedData() PASSED

TransactionsTest > testSendOffsetsToTransactionTimeout() STARTED

TransactionsTest > testSendOffsetsToTransactionTimeout() PASSED

TransactionsTest > testFailureToFenceEpoch() STARTED

TransactionsTest > testFailureToFenceEpoch() PASSED

TransactionsTest > testFencingOnSend() STARTED

TransactionsTest > testFencingOnSend() PASSED

TransactionsTest > testFencingOnCommit() STARTED

TransactionsTest > testFencingOnCommit() PASSED

TransactionsTest > testAbortTransactionTimeout() STARTED

TransactionsTest > testAbortTransactionTimeout() PASSED

TransactionsTest > testMultipleMarkersOneLeader() STARTED

TransactionsTest > testMultipleMarkersOneLeader() PASSED

TransactionsTest > testCommitTransactionTimeout() STARTED

TransactionsTest > testCommitTransactionTimeout() PASSED

SaslClientsWithInvalidCredentialsTest > 
testTransactionalProducerWithAuthenticationFailure() STARTED

SaslClientsWithInvalidCredentialsTest > 
testTransactionalProducerWithAuthenticationFailure() PASSED

SaslClientsWithInvalidCredentialsTest > 
testManualAssignmentConsumerWithAuthenticationFailure() STARTED

SaslClientsWithInvalidCredentialsTest > 
testManualAssignmentConsumerWithAuthenticationFailure() PASSED

SaslClientsWithInvalidCredentialsTest > 
testConsumerGroupServiceWithAuthenticationSuccess() STARTED

SaslClientsWithInvalidCredentialsTest > 
testConsumerGroupServiceWithAuthenticationSuccess() PASSED

SaslClientsWithInvalidCredentialsTest > testProducerWithAuthenticationFailure() 
STARTED

SaslClientsWithInvalidCredentialsTest > testProducerWithAuthenticationFailure() 
PASSED

SaslClientsWithInvalidCredentialsTest > 
testConsumerGroupServiceWithAuthenticationFailure() STARTED

SaslClientsWithInvalidCredentialsTest > 
testConsumerGroupServiceWithAuthenticationFailure() PASSED

SaslClientsWithInvalidCredentialsTest > 
testManualAssignmentConsumerWithAutoCommitDisabledWithAuthenticationFailure() 
STARTED

SaslClientsWithInvalidCredentialsTest > 
testManualAssignmentConsumerWithAutoCommitDisabledWithAuthenticationFailure() 
PASSED

SaslClientsWithInvalidCredentialsTest > 
testKafkaAdminClientWithAuthenticationFailure() STARTED

SaslClientsWithInvalidCredentialsTest > 
testKafkaAdminClientWithAuthenticationFailure() PASSED

SaslClientsWithInvalidCredentialsTest > testConsumerWithAuthenticationFailure() 
STARTED

SaslClientsWithInvalidCredentialsTest > testConsumerWithAuthenticationFailure() 
PASSED

UserClientIdQuotaTest > testProducerConsumerOverrideLowerQuota() STARTED

UserClientIdQuotaTest > testProducerConsumerOverrideLowerQuota() PASSED

UserClientIdQuotaTest > testProducerConsumerOverrideUnthrottled() STARTED

UserClientIdQuotaTest > testProducerConsumerOverrideUnthrottled() PASSED

UserClientIdQuotaTest > testThrottledProducerConsumer() STARTED

UserClientIdQuotaTest > testThrottledProducerConsumer() PASSED

UserClientIdQuotaTest > testQuotaOverrideDelete() STARTED

UserClientIdQuotaTest > testQuotaOverrideDelete() PASSED

UserClientIdQuotaTest > testThrottledRequest() STARTED

UserClientIdQuotaTest > testThrottledRequest() PASSED

ZooKeeperClientTest > testZNodeChangeHandlerForDataChange() STARTED

ZooKeeperClientTest > testZNodeChangeHandlerForDataChange() PASSED

ZooKeeperClientTest > testZooKeeperSessionStateMetric() STARTED

ZooKeeperClientTest > testZooKeeperSessionStateMetric() PASSED

ZooKeeperClientTest > testExceptionInBeforeInitializingSession() STARTED

ZooKeeperClientTest > testExceptionInBeforeInitializingSession() PASSED

ZooKeeperClientTest > testGetChildrenExistingZNode() STARTED

ZooKeeperClientTest > testGetChildrenExistingZNode() PASSED

ZooKeeperClientTest > testConnection() STARTED

ZooKeeperClientTest > testConnection() PASSED

ZooKeeperClientTest > testZNodeChangeHandlerForCreation() STARTED

ZooKeeperClientTest > testZNodeChangeHandlerForCreation() PASSED

ZooKeeperClientTest > testGetAclExistingZNode() STARTED

ZooKeeperClientTest > testGetAclExistingZNode() PASSED

ZooKeeperClientTest > testSessionExpiryDuringClose() STARTED

ZooKeeperClientTest > testSessionExpiryDuringClose() PASSED

ZooKeeperClientTest > testReinitializeAfterAuthFailure() STARTED

ZooKeeperClientTest > testReinitializeAfterAuthFailure() PASSED

ZooKeeperClientTest > testSetAclNonExistentZNode() STARTED

ZooKeeperClientTest > testSetAclNonExistentZNode() PASSED

ZooKeeperClientTest > testConnectionLossRequestTermination() STARTED

ZooKeeperClientTest > testConnectionLossRequestTermination() PASSED

ZooKeeperClientTest > testExistsNonExistentZNode() STARTED

ZooKeeperClientTest > testExistsNonExistentZNode() PASSED

[jira] [Resolved] (KAFKA-12211) NoSuchFileException will be thrown if hasPersistentStores is false when creating stateDir

[A. Sophie Blee-Goldman (Jira)]

 [ 
https://issues.apache.org/jira/browse/KAFKA-12211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

A. Sophie Blee-Goldman resolved KAFKA-12211.

Resolution: Fixed

> NoSuchFileException will be thrown if hasPersistentStores is false when 
> creating stateDir
> -
>
> Key: KAFKA-12211
> URL: https://issues.apache.org/jira/browse/KAFKA-12211
> Project: Kafka
>  Issue Type: Bug
>  Components: streams
>Affects Versions: 2.7.0, 2.6.1
>Reporter: Luke Chen
>Assignee: Luke Chen
>Priority: Minor
> Fix For: 2.8.0, 2.7.1, 2.6.2
>
>
> We improved the state directory folder/file permission setting in 
> KAFKA-10705. But we forgot to consider one situation: if user doesn't have 
> PersistentStores, we won't need to create base dir and state dir. And if 
> there's no such dir/file, and we tried to set permission to them, we'll have 
> *NoSuchFileException*
>  
> {code:java}
> ERROR Error changing permissions for the state or base directory 
> /var/folders/4l/393lkmzx3zvftwynjngzdsfwgn/T/kafka-11254487964259813330/appId_AdjustStreamThreadCountTestshouldAddStreamThread
>   (org.apache.kafka.streams.processor.internals.StateDirectory:117)
> 2021-01-15T16:10:44.570+0800 [DEBUG] [TestEventLogger] 
> java.nio.file.NoSuchFileException: 
> /var/folders/4l/393lkmzx3zvftwynjngzdsfwgn/T/kafka-11254487964259813330/appId_AdjustStreamThreadCountTestshouldAddStreamThread
> 2021-01-15T16:10:44.570+0800 [DEBUG] [TestEventLogger]  at 
> java.base/sun.nio.fs.UnixException.translateToIOException(UnixException.java:92)
> 2021-01-15T16:10:44.570+0800 [DEBUG] [TestEventLogger]  at 
> java.base/sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:111)
> 2021-01-15T16:10:44.570+0800 [DEBUG] [TestEventLogger]  at 
> java.base/sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:116)
> 2021-01-15T16:10:44.570+0800 [DEBUG] [TestEventLogger]  at 
> java.base/sun.nio.fs.UnixFileAttributeViews$Posix.setMode(UnixFileAttributeViews.java:254)
> 2021-01-15T16:10:44.570+0800 [DEBUG] [TestEventLogger]  at 
> java.base/sun.nio.fs.UnixFileAttributeViews$Posix.setPermissions(UnixFileAttributeViews.java:276)
> 2021-01-15T16:10:44.570+0800 [DEBUG] [TestEventLogger]  at 
> java.base/java.nio.file.Files.setPosixFilePermissions(Files.java:2079)
> 2021-01-15T16:10:44.570+0800 [DEBUG] [TestEventLogger]  at 
> org.apache.kafka.streams.processor.internals.StateDirectory.(StateDirectory.java:115)
> {code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #567

[Apache Jenkins Server]

See 


Changes:

[github] KAFKA-12267; Implement `DescribeTransactions` API (#10183)


--
[...truncated 3.66 MB...]

ConsoleConsumerTest > shouldResetUnConsumedOffsetsBeforeExit() STARTED

ConsoleConsumerTest > shouldResetUnConsumedOffsetsBeforeExit() PASSED

ConsoleConsumerTest > shouldParseConfigsFromFile() STARTED

ConsoleConsumerTest > shouldParseConfigsFromFile() PASSED

ConsoleConsumerTest > shouldParseValidConsumerConfigWithAutoOffsetResetLatest() 
STARTED

ConsoleConsumerTest > shouldParseValidConsumerConfigWithAutoOffsetResetLatest() 
PASSED

ConsoleConsumerTest > groupIdsProvidedInDifferentPlacesMustMatch() STARTED

ConsoleConsumerTest > groupIdsProvidedInDifferentPlacesMustMatch() PASSED

ConsoleConsumerTest > 
shouldParseValidConsumerConfigWithAutoOffsetResetAndMatchingFromBeginning() 
STARTED

ConsoleConsumerTest > 
shouldParseValidConsumerConfigWithAutoOffsetResetAndMatchingFromBeginning() 
PASSED

ConsoleConsumerTest > shouldExitOnGroupIdAndPartitionGivenTogether() STARTED

ConsoleConsumerTest > shouldExitOnGroupIdAndPartitionGivenTogether() PASSED

ConsoleConsumerTest > shouldExitOnUnrecognizedNewConsumerOption() STARTED

ConsoleConsumerTest > shouldExitOnUnrecognizedNewConsumerOption() PASSED

ConsoleConsumerTest > 
shouldParseValidSimpleConsumerValidConfigWithNumericOffset() STARTED

ConsoleConsumerTest > 
shouldParseValidSimpleConsumerValidConfigWithNumericOffset() PASSED

ConsoleConsumerTest > 
shouldParseValidConsumerConfigWithAutoOffsetResetEarliest() STARTED

ConsoleConsumerTest > 
shouldParseValidConsumerConfigWithAutoOffsetResetEarliest() PASSED

ConsoleConsumerTest > testNoOpMessageFormatter() STARTED

ConsoleConsumerTest > testNoOpMessageFormatter() PASSED

ConsoleConsumerTest > 
shouldParseValidSimpleConsumerValidConfigWithStringOffset() STARTED

ConsoleConsumerTest > 
shouldParseValidSimpleConsumerValidConfigWithStringOffset() PASSED

ConsoleConsumerTest > testDefaultMessageFormatter() STARTED

ConsoleConsumerTest > testDefaultMessageFormatter() PASSED

ConsoleConsumerTest > testCustomPropertyShouldBePassedToConfigureMethod() 
STARTED

ConsoleConsumerTest > testCustomPropertyShouldBePassedToConfigureMethod() PASSED

ConsoleConsumerTest > shouldParseValidConsumerValidConfig() STARTED

ConsoleConsumerTest > shouldParseValidConsumerValidConfig() PASSED

ConsoleConsumerTest > shouldParseValidConsumerConfigWithNoOffsetReset() STARTED

ConsoleConsumerTest > shouldParseValidConsumerConfigWithNoOffsetReset() PASSED

GetOffsetShellParsingTest > testPartitionFilterForLowerBound() STARTED

GetOffsetShellParsingTest > testPartitionFilterForLowerBound() PASSED

GetOffsetShellParsingTest > testPartitionFilterForRange() STARTED

GetOffsetShellParsingTest > testPartitionFilterForRange() PASSED

GetOffsetShellParsingTest > [1] excludeInternal=true STARTED

GetOffsetShellParsingTest > [1] excludeInternal=true PASSED

GetOffsetShellParsingTest > [2] excludeInternal=false STARTED

GetOffsetShellParsingTest > [2] excludeInternal=false PASSED

GetOffsetShellParsingTest > testPartitionFilterForInvalidSingleIndex() STARTED

GetOffsetShellParsingTest > testPartitionFilterForInvalidSingleIndex() PASSED

GetOffsetShellParsingTest > [1] excludeInternal=true STARTED

GetOffsetShellParsingTest > [1] excludeInternal=true PASSED

GetOffsetShellParsingTest > [2] excludeInternal=false STARTED

GetOffsetShellParsingTest > [2] excludeInternal=false PASSED

GetOffsetShellParsingTest > testPartitionFilterForUpperBound() STARTED

GetOffsetShellParsingTest > testPartitionFilterForUpperBound() PASSED

GetOffsetShellParsingTest > testPartitionFilterForInvalidLowerBound() STARTED

GetOffsetShellParsingTest > testPartitionFilterForInvalidLowerBound() PASSED

GetOffsetShellParsingTest > [1] excludeInternal=true STARTED

GetOffsetShellParsingTest > [1] excludeInternal=true PASSED

GetOffsetShellParsingTest > [2] excludeInternal=false STARTED

GetOffsetShellParsingTest > [2] excludeInternal=false PASSED

GetOffsetShellParsingTest > [1] excludeInternal=true STARTED

GetOffsetShellParsingTest > [1] excludeInternal=true PASSED

GetOffsetShellParsingTest > [2] excludeInternal=false STARTED

GetOffsetShellParsingTest > [2] excludeInternal=false PASSED

GetOffsetShellParsingTest > [1] excludeInternal=true STARTED

GetOffsetShellParsingTest > [1] excludeInternal=true PASSED

GetOffsetShellParsingTest > [2] excludeInternal=false STARTED

GetOffsetShellParsingTest > [2] excludeInternal=false PASSED

GetOffsetShellParsingTest > [1] excludeInternal=true STARTED

GetOffsetShellParsingTest > [1] excludeInternal=true PASSED

GetOffsetShellParsingTest > [2] excludeInternal=false STARTED

GetOffsetShellParsingTest > [2] excludeInternal=false PASSED

GetOffsetShellParsingTest > [1] excludeInternal=true STARTED

GetOffsetShellParsingTest > [1] excludeInternal=true PASSED

GetOffsetShellParsingTest > [2] 

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #509

[Apache Jenkins Server]

See 


Changes:

[github] MINOR: Add release documentation for KIP-614 (#10051)

[github] MINOR: Fix the generation extraction util (#10204)

[github] KAFKA-12267; Implement `DescribeTransactions` API (#10183)


--
[...truncated 3.65 MB...]

LogTest > testLastStableOffsetDoesNotExceedLogStartOffsetMidSegment() STARTED

LogTest > testLastStableOffsetDoesNotExceedLogStartOffsetMidSegment() PASSED

LogTest > testDeleteSnapshotsOnIncrementLogStartOffset() STARTED

LogTest > testDeleteSnapshotsOnIncrementLogStartOffset() PASSED

LogTest > testCorruptIndexRebuild() STARTED

LogTest > testCorruptIndexRebuild() PASSED

LogTest > shouldDeleteTimeBasedSegmentsReadyToBeDeleted() STARTED

LogTest > shouldDeleteTimeBasedSegmentsReadyToBeDeleted() PASSED

LogTest > testReadWithTooSmallMaxLength() STARTED

LogTest > testReadWithTooSmallMaxLength() PASSED

LogTest > testOverCompactedLogRecovery() STARTED

LogTest > testOverCompactedLogRecovery() PASSED

LogTest > testBogusIndexSegmentsAreRemoved() STARTED

LogTest > testBogusIndexSegmentsAreRemoved() PASSED

LogTest > testLeaderEpochCacheClearedAfterStaticMessageFormatDowngrade() STARTED

LogTest > testLeaderEpochCacheClearedAfterStaticMessageFormatDowngrade() PASSED

LogTest > testCompressedMessages() STARTED

LogTest > testCompressedMessages() PASSED

LogTest > testAppendMessageWithNullPayload() STARTED

LogTest > testAppendMessageWithNullPayload() PASSED

LogTest > testCorruptLog() STARTED

LogTest > testCorruptLog() PASSED

LogTest > testLogRecoversToCorrectOffset() STARTED

LogTest > testLogRecoversToCorrectOffset() PASSED

LogTest > testReopenThenTruncate() STARTED

LogTest > testReopenThenTruncate() PASSED

LogTest > testZombieCoordinatorFenced() STARTED

LogTest > testZombieCoordinatorFenced() PASSED

LogTest > testOldProducerEpoch() STARTED

LogTest > testOldProducerEpoch() PASSED

LogTest > testProducerSnapshotsRecoveryAfterUncleanShutdownV1() STARTED

LogTest > testProducerSnapshotsRecoveryAfterUncleanShutdownV1() PASSED

LogTest > testDegenerateSegmentSplit() STARTED

LogTest > testDegenerateSegmentSplit() PASSED

LogTest > testParseTopicPartitionNameForMissingPartition() STARTED

LogTest > testParseTopicPartitionNameForMissingPartition() PASSED

LogTest > testParseTopicPartitionNameForEmptyName() STARTED

LogTest > testParseTopicPartitionNameForEmptyName() PASSED

LogTest > testOffsetSnapshot() STARTED

LogTest > testOffsetSnapshot() PASSED

LogTest > testOpenDeletesObsoleteFiles() STARTED

LogTest > testOpenDeletesObsoleteFiles() PASSED

LogTest > shouldUpdateOffsetForLeaderEpochsWhenDeletingSegments() STARTED

LogTest > shouldUpdateOffsetForLeaderEpochsWhenDeletingSegments() PASSED

LogTest > testLogDeleteDirName() STARTED

LogTest > testLogDeleteDirName() PASSED

LogTest > testDeleteOldSegments() STARTED

LogTest > testDeleteOldSegments() PASSED

LogTest > testRebuildTimeIndexForOldMessages() STARTED

LogTest > testRebuildTimeIndexForOldMessages() PASSED

LogTest > testProducerIdMapTruncateTo() STARTED

LogTest > testProducerIdMapTruncateTo() PASSED

LogTest > testTakeSnapshotOnRollAndDeleteSnapshotOnRecoveryPointCheckpoint() 
STARTED

LogTest > testTakeSnapshotOnRollAndDeleteSnapshotOnRecoveryPointCheckpoint() 
PASSED

LogTest > testLogEndLessThanStartAfterReopen() STARTED

LogTest > testLogEndLessThanStartAfterReopen() PASSED

LogTest > testLogRecoversForLeaderEpoch() STARTED

LogTest > testLogRecoversForLeaderEpoch() PASSED

LogTest > testRetentionDeletesProducerStateSnapshots() STARTED

LogTest > testRetentionDeletesProducerStateSnapshots() PASSED

LogTest > testLoadingLogDeletesProducerStateSnapshotsPastLogEndOffset() STARTED

LogTest > testLoadingLogDeletesProducerStateSnapshotsPastLogEndOffset() PASSED

LogTest > testWriteLeaderEpochCheckpointAfterDirectoryRename() STARTED

LogTest > testWriteLeaderEpochCheckpointAfterDirectoryRename() PASSED

LogTest > testOverCompactedLogRecoveryMultiRecord() STARTED

LogTest > testOverCompactedLogRecoveryMultiRecord() PASSED

LogTest > testSizeBasedLogRoll() STARTED

LogTest > testSizeBasedLogRoll() PASSED

LogTest > testRebuildProducerIdMapWithCompactedData() STARTED

LogTest > testRebuildProducerIdMapWithCompactedData() PASSED

LogTest > shouldNotDeleteSizeBasedSegmentsWhenUnderRetentionSize() STARTED

LogTest > shouldNotDeleteSizeBasedSegmentsWhenUnderRetentionSize() PASSED

LogTest > testTransactionIndexUpdatedThroughReplication() STARTED

LogTest > testTransactionIndexUpdatedThroughReplication() PASSED

LogTest > testTimeBasedLogRollJitter() STARTED

LogTest > testTimeBasedLogRollJitter() PASSED

LogTest > testParseTopicPartitionName() STARTED

LogTest > testParseTopicPartitionName() PASSED

LogTest > testEndTxnWithFencedProducerEpoch() STARTED

LogTest > testEndTxnWithFencedProducerEpoch() PASSED

LogTest > testRecoveryOfSegmentWithOffsetOverflow() STARTED

LogTest > 

Jenkins build is back to normal : Kafka » kafka-2.8-jdk8 #37

[Apache Jenkins Server]

See 

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #540

[Apache Jenkins Server]

See 


Changes:

[github] MINOR: Add release documentation for KIP-614 (#10051)

[github] MINOR: Fix the generation extraction util (#10204)

[github] KAFKA-12267; Implement `DescribeTransactions` API (#10183)


--
[...truncated 3.66 MB...]

KafkaZkClientTest > testIsrChangeNotificationsDeletion() STARTED

KafkaZkClientTest > testIsrChangeNotificationsDeletion() PASSED

KafkaZkClientTest > testGetDataAndVersion() STARTED

KafkaZkClientTest > testGetDataAndVersion() PASSED

KafkaZkClientTest > testGetChildren() STARTED

KafkaZkClientTest > testGetChildren() PASSED

KafkaZkClientTest > testSetAndGetConsumerOffset() STARTED

KafkaZkClientTest > testSetAndGetConsumerOffset() PASSED

KafkaZkClientTest > testClusterIdMethods() STARTED

KafkaZkClientTest > testClusterIdMethods() PASSED

KafkaZkClientTest > testEntityConfigManagementMethods() STARTED

KafkaZkClientTest > testEntityConfigManagementMethods() PASSED

KafkaZkClientTest > testUpdateLeaderAndIsr() STARTED

KafkaZkClientTest > testUpdateLeaderAndIsr() PASSED

KafkaZkClientTest > testUpdateBrokerInfo() STARTED

KafkaZkClientTest > testUpdateBrokerInfo() PASSED

KafkaZkClientTest > testCreateRecursive() STARTED

KafkaZkClientTest > testCreateRecursive() PASSED

KafkaZkClientTest > testGetConsumerOffsetNoData() STARTED

KafkaZkClientTest > testGetConsumerOffsetNoData() PASSED

KafkaZkClientTest > testDeleteTopicPathMethods() STARTED

KafkaZkClientTest > testDeleteTopicPathMethods() PASSED

KafkaZkClientTest > testSetTopicPartitionStatesRaw() STARTED

KafkaZkClientTest > testSetTopicPartitionStatesRaw() PASSED

KafkaZkClientTest > testAclManagementMethods() STARTED

KafkaZkClientTest > testAclManagementMethods() PASSED

KafkaZkClientTest > testPreferredReplicaElectionMethods() STARTED

KafkaZkClientTest > testPreferredReplicaElectionMethods() PASSED

KafkaZkClientTest > testPropagateLogDir() STARTED

KafkaZkClientTest > testPropagateLogDir() PASSED

KafkaZkClientTest > testGetDataAndStat() STARTED

KafkaZkClientTest > testGetDataAndStat() PASSED

KafkaZkClientTest > testReassignPartitionsInProgress() STARTED

KafkaZkClientTest > testReassignPartitionsInProgress() PASSED

KafkaZkClientTest > testCreateTopLevelPaths() STARTED

KafkaZkClientTest > testCreateTopLevelPaths() PASSED

KafkaZkClientTest > testGetAllTopicsInClusterDoesNotTriggerWatch() STARTED

KafkaZkClientTest > testGetAllTopicsInClusterDoesNotTriggerWatch() PASSED

KafkaZkClientTest > testIsrChangeNotificationGetters() STARTED

KafkaZkClientTest > testIsrChangeNotificationGetters() PASSED

KafkaZkClientTest > testLogDirEventNotificationsDeletion() STARTED

KafkaZkClientTest > testLogDirEventNotificationsDeletion() PASSED

KafkaZkClientTest > testGetLogConfigs() STARTED

KafkaZkClientTest > testGetLogConfigs() PASSED

KafkaZkClientTest > testBrokerSequenceIdMethods() STARTED

KafkaZkClientTest > testBrokerSequenceIdMethods() PASSED

KafkaZkClientTest > testAclMethods() STARTED

KafkaZkClientTest > testAclMethods() PASSED

KafkaZkClientTest > testCreateSequentialPersistentPath() STARTED

KafkaZkClientTest > testCreateSequentialPersistentPath() PASSED

KafkaZkClientTest > testConditionalUpdatePath() STARTED

KafkaZkClientTest > testConditionalUpdatePath() PASSED

KafkaZkClientTest > testGetAllTopicsInClusterTriggersWatch() STARTED

KafkaZkClientTest > testGetAllTopicsInClusterTriggersWatch() PASSED

KafkaZkClientTest > testDeleteTopicZNode() STARTED

KafkaZkClientTest > testDeleteTopicZNode() PASSED

KafkaZkClientTest > testDeletePath() STARTED

KafkaZkClientTest > testDeletePath() PASSED

KafkaZkClientTest > testGetBrokerMethods() STARTED

KafkaZkClientTest > testGetBrokerMethods() PASSED

KafkaZkClientTest > testCreateTokenChangeNotification() STARTED

KafkaZkClientTest > testCreateTokenChangeNotification() PASSED

KafkaZkClientTest > testGetTopicsAndPartitions() STARTED

KafkaZkClientTest > testGetTopicsAndPartitions() PASSED

KafkaZkClientTest > testRegisterBrokerInfo() STARTED

KafkaZkClientTest > testRegisterBrokerInfo() PASSED

KafkaZkClientTest > testRetryRegisterBrokerInfo() STARTED

KafkaZkClientTest > testRetryRegisterBrokerInfo() PASSED

KafkaZkClientTest > testConsumerOffsetPath() STARTED

KafkaZkClientTest > testConsumerOffsetPath() PASSED

KafkaZkClientTest > testDeleteRecursiveWithControllerEpochVersionCheck() STARTED

KafkaZkClientTest > testDeleteRecursiveWithControllerEpochVersionCheck() PASSED

KafkaZkClientTest > testTopicAssignments() STARTED

KafkaZkClientTest > testTopicAssignments() PASSED

KafkaZkClientTest > testControllerManagementMethods() STARTED

KafkaZkClientTest > testControllerManagementMethods() PASSED

KafkaZkClientTest > testTopicAssignmentMethods() STARTED

KafkaZkClientTest > testTopicAssignmentMethods() PASSED

KafkaZkClientTest > testConnectionViaNettyClient() STARTED

KafkaZkClientTest > testConnectionViaNettyClient() PASSED

[jira] [Created] (KAFKA-12374) Add missing config sasl.mechanism.controller.protocol

[Ron Dagostino (Jira)]

Ron Dagostino created KAFKA-12374:
-

 Summary: Add missing config sasl.mechanism.controller.protocol
 Key: KAFKA-12374
 URL: https://issues.apache.org/jira/browse/KAFKA-12374
 Project: Kafka
  Issue Type: Bug
  Components: config
Affects Versions: 2.8.0
Reporter: Ron Dagostino
Assignee: Ron Dagostino
 Fix For: 2.8.0


The config `sasl.mechanism.controller.protocol` from KIP-631 is not 
implemented.  Furthermore, `KafkaRaftManager` is using inter-broker security 
information when it connects to the Raft controller quorum.  KafkaRaftClient 
should use the first entry in `controller.listener.names` to determine the 
listener name; that listener name's mapped value in the 
`listener.security.protocol.map` (if such a mapping exists, otherwise the 
listener name itself) for the security protocol; and the value of 
`sasl.mechanism.controller.protocol` for the SASL mechanism.  Finally, 
`RaftControllerNodeProvider` needs to use the value of 
`sasl.mechanism.controller.protocol` instead of the inter-broker sasl mechanism 
(it currently determines the listener name and security protocol correctly)



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #566

[Apache Jenkins Server]

See 


Changes:

[github] MINOR: Add release documentation for KIP-614 (#10051)

[github] MINOR: Fix the generation extraction util (#10204)


--
[...truncated 3.67 MB...]

AclAuthorizerTest > testAuthorizeByResourceTypeWildcardResourceDenyDominate() 
STARTED

AclAuthorizerTest > testAuthorizeByResourceTypeWildcardResourceDenyDominate() 
PASSED

AclAuthorizerTest > testEmptyAclThrowsException() STARTED

AclAuthorizerTest > testEmptyAclThrowsException() PASSED

AclAuthorizerTest > testAuthorizeByResourceTypeNoAclFoundOverride() STARTED

AclAuthorizerTest > testAuthorizeByResourceTypeNoAclFoundOverride() PASSED

AclAuthorizerTest > testSuperUserWithCustomPrincipalHasAccess() STARTED

AclAuthorizerTest > testSuperUserWithCustomPrincipalHasAccess() PASSED

AclAuthorizerTest > testAuthorizeByResourceTypeWithAllOperationAce() STARTED

AclAuthorizerTest > testAuthorizeByResourceTypeWithAllOperationAce() PASSED

AclAuthorizerTest > testAllowAccessWithCustomPrincipal() STARTED

AclAuthorizerTest > testAllowAccessWithCustomPrincipal() PASSED

AclAuthorizerTest > testDeleteAclOnWildcardResource() STARTED

AclAuthorizerTest > testDeleteAclOnWildcardResource() PASSED

AclAuthorizerTest > testAuthorizerZkConfigFromKafkaConfig() STARTED

AclAuthorizerTest > testAuthorizerZkConfigFromKafkaConfig() PASSED

AclAuthorizerTest > testChangeListenerTiming() STARTED

AclAuthorizerTest > testChangeListenerTiming() PASSED

AclAuthorizerTest > 
testWritesLiteralWritesLiteralAclChangeEventWhenInterBrokerProtocolLessThanKafkaV2eralAclChangesForOlderProtocolVersions()
 STARTED

AclAuthorizerTest > 
testWritesLiteralWritesLiteralAclChangeEventWhenInterBrokerProtocolLessThanKafkaV2eralAclChangesForOlderProtocolVersions()
 PASSED

AclAuthorizerTest > testAuthorzeByResourceTypeSuperUserHasAccess() STARTED

AclAuthorizerTest > testAuthorzeByResourceTypeSuperUserHasAccess() PASSED

AclAuthorizerTest > testAuthorizeByResourceTypePrefixedResourceDenyDominate() 
STARTED

AclAuthorizerTest > testAuthorizeByResourceTypePrefixedResourceDenyDominate() 
PASSED

AclAuthorizerTest > testAuthorizeByResourceTypeMultipleAddAndRemove() 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

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

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #508

[Apache Jenkins Server]

See 


Changes:

[github] KAFKA-12350: Correct the default value in doc (#10165)


--
[...truncated 7.29 MB...]

LogTest > testLastStableOffsetDoesNotExceedLogStartOffsetMidSegment() STARTED

LogTest > testLastStableOffsetDoesNotExceedLogStartOffsetMidSegment() PASSED

LogTest > testDeleteSnapshotsOnIncrementLogStartOffset() STARTED

LogTest > testDeleteSnapshotsOnIncrementLogStartOffset() PASSED

LogTest > testCorruptIndexRebuild() STARTED

LogTest > testCorruptIndexRebuild() PASSED

LogTest > shouldDeleteTimeBasedSegmentsReadyToBeDeleted() STARTED

LogTest > shouldDeleteTimeBasedSegmentsReadyToBeDeleted() PASSED

LogTest > testReadWithTooSmallMaxLength() STARTED

LogTest > testReadWithTooSmallMaxLength() PASSED

LogTest > testOverCompactedLogRecovery() STARTED

LogTest > testOverCompactedLogRecovery() PASSED

LogTest > testBogusIndexSegmentsAreRemoved() STARTED

LogTest > testBogusIndexSegmentsAreRemoved() PASSED

LogTest > testLeaderEpochCacheClearedAfterStaticMessageFormatDowngrade() STARTED

LogTest > testLeaderEpochCacheClearedAfterStaticMessageFormatDowngrade() PASSED

LogTest > testCompressedMessages() STARTED

LogTest > testCompressedMessages() PASSED

LogTest > testAppendMessageWithNullPayload() STARTED

LogTest > testAppendMessageWithNullPayload() PASSED

LogTest > testCorruptLog() STARTED

LogTest > testCorruptLog() PASSED

LogTest > testLogRecoversToCorrectOffset() STARTED

LogTest > testLogRecoversToCorrectOffset() PASSED

LogTest > testReopenThenTruncate() STARTED

LogTest > testReopenThenTruncate() PASSED

LogTest > testZombieCoordinatorFenced() STARTED

LogTest > testZombieCoordinatorFenced() PASSED

LogTest > testOldProducerEpoch() STARTED

LogTest > testOldProducerEpoch() PASSED

LogTest > testProducerSnapshotsRecoveryAfterUncleanShutdownV1() STARTED

LogTest > testProducerSnapshotsRecoveryAfterUncleanShutdownV1() PASSED

LogTest > testDegenerateSegmentSplit() STARTED

LogTest > testDegenerateSegmentSplit() PASSED

LogTest > testParseTopicPartitionNameForMissingPartition() STARTED

LogTest > testParseTopicPartitionNameForMissingPartition() PASSED

LogTest > testParseTopicPartitionNameForEmptyName() STARTED

LogTest > testParseTopicPartitionNameForEmptyName() PASSED

LogTest > testOffsetSnapshot() STARTED

LogTest > testOffsetSnapshot() PASSED

LogTest > testOpenDeletesObsoleteFiles() STARTED

LogTest > testOpenDeletesObsoleteFiles() PASSED

LogTest > shouldUpdateOffsetForLeaderEpochsWhenDeletingSegments() STARTED

LogTest > shouldUpdateOffsetForLeaderEpochsWhenDeletingSegments() PASSED

LogTest > testLogDeleteDirName() STARTED

LogTest > testLogDeleteDirName() PASSED

LogTest > testDeleteOldSegments() STARTED

LogTest > testDeleteOldSegments() PASSED

LogTest > testRebuildTimeIndexForOldMessages() STARTED

LogTest > testRebuildTimeIndexForOldMessages() PASSED

LogTest > testProducerIdMapTruncateTo() STARTED

LogTest > testProducerIdMapTruncateTo() PASSED

LogTest > testTakeSnapshotOnRollAndDeleteSnapshotOnRecoveryPointCheckpoint() 
STARTED

LogTest > testTakeSnapshotOnRollAndDeleteSnapshotOnRecoveryPointCheckpoint() 
PASSED

LogTest > testLogEndLessThanStartAfterReopen() STARTED

LogTest > testLogEndLessThanStartAfterReopen() PASSED

LogTest > testLogRecoversForLeaderEpoch() STARTED

LogTest > testLogRecoversForLeaderEpoch() PASSED

LogTest > testRetentionDeletesProducerStateSnapshots() STARTED

LogTest > testRetentionDeletesProducerStateSnapshots() PASSED

LogTest > testLoadingLogDeletesProducerStateSnapshotsPastLogEndOffset() STARTED

LogTest > testLoadingLogDeletesProducerStateSnapshotsPastLogEndOffset() PASSED

LogTest > testWriteLeaderEpochCheckpointAfterDirectoryRename() STARTED

LogTest > testWriteLeaderEpochCheckpointAfterDirectoryRename() PASSED

LogTest > testOverCompactedLogRecoveryMultiRecord() STARTED

LogTest > testOverCompactedLogRecoveryMultiRecord() PASSED

LogTest > testSizeBasedLogRoll() STARTED

LogTest > testSizeBasedLogRoll() PASSED

LogTest > testRebuildProducerIdMapWithCompactedData() STARTED

LogTest > testRebuildProducerIdMapWithCompactedData() PASSED

LogTest > shouldNotDeleteSizeBasedSegmentsWhenUnderRetentionSize() STARTED

LogTest > shouldNotDeleteSizeBasedSegmentsWhenUnderRetentionSize() PASSED

LogTest > testTransactionIndexUpdatedThroughReplication() STARTED

LogTest > testTransactionIndexUpdatedThroughReplication() PASSED

LogTest > testTimeBasedLogRollJitter() STARTED

LogTest > testTimeBasedLogRollJitter() PASSED

LogTest > testParseTopicPartitionName() STARTED

LogTest > testParseTopicPartitionName() PASSED

LogTest > testEndTxnWithFencedProducerEpoch() STARTED

LogTest > testEndTxnWithFencedProducerEpoch() PASSED

LogTest > testRecoveryOfSegmentWithOffsetOverflow() STARTED

LogTest > testRecoveryOfSegmentWithOffsetOverflow() PASSED

LogTest > testRecoverAfterNonMonotonicCoordinatorEpochWrite() STARTED

LogTest > 

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #539

[Apache Jenkins Server]

See 


Changes:

[github] KAFKA-12350: Correct the default value in doc (#10165)


--
[...truncated 7.33 MB...]

SocketServerTest > testConnectionId() STARTED

SocketServerTest > testConnectionId() PASSED

SocketServerTest > remoteCloseSendFailure() STARTED

SocketServerTest > remoteCloseSendFailure() PASSED

SocketServerTest > testBrokerSendAfterChannelClosedUpdatesRequestMetrics() 
STARTED

SocketServerTest > testBrokerSendAfterChannelClosedUpdatesRequestMetrics() 
PASSED

SocketServerTest > 
testControlPlaneTakePrecedenceOverInterBrokerListenerAsPrivilegedListener() 
STARTED

SocketServerTest > 
testControlPlaneTakePrecedenceOverInterBrokerListenerAsPrivilegedListener() 
PASSED

SocketServerTest > testNoOpAction() STARTED

SocketServerTest > testNoOpAction() PASSED

SocketServerTest > simpleRequest() STARTED

SocketServerTest > simpleRequest() PASSED

SocketServerTest > 
testSendActionResponseWithThrottledChannelWhereThrottlingInProgress() STARTED

SocketServerTest > 
testSendActionResponseWithThrottledChannelWhereThrottlingInProgress() PASSED

SocketServerTest > testIdleConnection() STARTED

SocketServerTest > testIdleConnection() PASSED

SocketServerTest > remoteCloseWithoutBufferedReceives() STARTED

SocketServerTest > remoteCloseWithoutBufferedReceives() PASSED

SocketServerTest > remoteCloseWithCompleteAndIncompleteBufferedReceives() 
STARTED

SocketServerTest > remoteCloseWithCompleteAndIncompleteBufferedReceives() PASSED

SocketServerTest > testZeroMaxConnectionsPerIp() STARTED

SocketServerTest > testZeroMaxConnectionsPerIp() PASSED

SocketServerTest > testClientInformationWithLatestApiVersionsRequest() STARTED

SocketServerTest > testClientInformationWithLatestApiVersionsRequest() PASSED

SocketServerTest > testMetricCollectionAfterShutdown() STARTED

SocketServerTest > testMetricCollectionAfterShutdown() PASSED

SocketServerTest > testSessionPrincipal() STARTED

SocketServerTest > testSessionPrincipal() PASSED

SocketServerTest > configureNewConnectionException() STARTED

SocketServerTest > configureNewConnectionException() PASSED

SocketServerTest > testSaslReauthenticationFailureWithKip152SaslAuthenticate() 
STARTED

SocketServerTest > testSaslReauthenticationFailureWithKip152SaslAuthenticate() 
PASSED

SocketServerTest > testMaxConnectionsPerIpOverrides() STARTED

SocketServerTest > testMaxConnectionsPerIpOverrides() PASSED

SocketServerTest > processNewResponseException() STARTED

SocketServerTest > processNewResponseException() PASSED

SocketServerTest > remoteCloseWithIncompleteBufferedReceive() STARTED

SocketServerTest > remoteCloseWithIncompleteBufferedReceive() PASSED

SocketServerTest > testStagedListenerShutdownWhenConnectionQueueIsFull() STARTED

SocketServerTest > testStagedListenerShutdownWhenConnectionQueueIsFull() PASSED

SocketServerTest > testStagedListenerStartup() STARTED

SocketServerTest > testStagedListenerStartup() PASSED

SocketServerTest > testConnectionRateLimit() STARTED

SocketServerTest > testConnectionRateLimit() PASSED

SocketServerTest > testConnectionRatePerIp() STARTED

SocketServerTest > testConnectionRatePerIp() PASSED

SocketServerTest > processCompletedSendException() STARTED

SocketServerTest > processCompletedSendException() PASSED

SocketServerTest > processDisconnectedException() STARTED

SocketServerTest > processDisconnectedException() PASSED

SocketServerTest > closingChannelWithBufferedReceives() STARTED

SocketServerTest > closingChannelWithBufferedReceives() PASSED

SocketServerTest > sendCancelledKeyException() STARTED

SocketServerTest > sendCancelledKeyException() PASSED

SocketServerTest > processCompletedReceiveException() STARTED

SocketServerTest > processCompletedReceiveException() PASSED

SocketServerTest > testControlPlaneAsPrivilegedListener() STARTED

SocketServerTest > testControlPlaneAsPrivilegedListener() PASSED

SocketServerTest > closingChannelSendFailure() STARTED

SocketServerTest > closingChannelSendFailure() PASSED

SocketServerTest > idleExpiryWithBufferedReceives() STARTED

SocketServerTest > idleExpiryWithBufferedReceives() PASSED

SocketServerTest > testSocketsCloseOnShutdown() STARTED

SocketServerTest > testSocketsCloseOnShutdown() PASSED

SocketServerTest > 
testNoOpActionResponseWithThrottledChannelWhereThrottlingAlreadyDone() STARTED

SocketServerTest > 
testNoOpActionResponseWithThrottledChannelWhereThrottlingAlreadyDone() PASSED

SocketServerTest > pollException() STARTED

SocketServerTest > pollException() PASSED

SocketServerTest > closingChannelWithBufferedReceivesFailedSend() STARTED

SocketServerTest > closingChannelWithBufferedReceivesFailedSend() PASSED

SocketServerTest > remoteCloseWithBufferedReceives() STARTED

SocketServerTest > remoteCloseWithBufferedReceives() PASSED

SocketServerTest > testThrottledSocketsClosedOnShutdown() STARTED

SocketServerTest > 

[jira] [Resolved] (KAFKA-12267) Implement DescribeTransactions API

[Jason Gustafson (Jira)]

 [ 
https://issues.apache.org/jira/browse/KAFKA-12267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Jason Gustafson resolved KAFKA-12267.
-
Resolution: Fixed

> Implement DescribeTransactions API
> --
>
> Key: KAFKA-12267
> URL: https://issues.apache.org/jira/browse/KAFKA-12267
> Project: Kafka
>  Issue Type: Sub-task
>Reporter: Jason Gustafson
>Assignee: Jason Gustafson
>Priority: Major
>




--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #565

[Apache Jenkins Server]

See 


Changes:

[github] KAFKA-12350: Correct the default value in doc (#10165)


--
[...truncated 7.33 MB...]

AclAuthorizerTest > testAuthorizeByResourceTypeWildcardResourceDenyDominate() 
STARTED

AclAuthorizerTest > testAuthorizeByResourceTypeWildcardResourceDenyDominate() 
PASSED

AclAuthorizerTest > testEmptyAclThrowsException() STARTED

AclAuthorizerTest > testEmptyAclThrowsException() PASSED

AclAuthorizerTest > testAuthorizeByResourceTypeNoAclFoundOverride() STARTED

AclAuthorizerTest > testAuthorizeByResourceTypeNoAclFoundOverride() PASSED

AclAuthorizerTest > testSuperUserWithCustomPrincipalHasAccess() STARTED

AclAuthorizerTest > testSuperUserWithCustomPrincipalHasAccess() PASSED

AclAuthorizerTest > testAuthorizeByResourceTypeWithAllOperationAce() STARTED

AclAuthorizerTest > testAuthorizeByResourceTypeWithAllOperationAce() PASSED

AclAuthorizerTest > testAllowAccessWithCustomPrincipal() STARTED

AclAuthorizerTest > testAllowAccessWithCustomPrincipal() PASSED

AclAuthorizerTest > testDeleteAclOnWildcardResource() STARTED

AclAuthorizerTest > testDeleteAclOnWildcardResource() PASSED

AclAuthorizerTest > testAuthorizerZkConfigFromKafkaConfig() STARTED

AclAuthorizerTest > testAuthorizerZkConfigFromKafkaConfig() PASSED

AclAuthorizerTest > testChangeListenerTiming() STARTED

AclAuthorizerTest > testChangeListenerTiming() PASSED

AclAuthorizerTest > 
testWritesLiteralWritesLiteralAclChangeEventWhenInterBrokerProtocolLessThanKafkaV2eralAclChangesForOlderProtocolVersions()
 STARTED

AclAuthorizerTest > 
testWritesLiteralWritesLiteralAclChangeEventWhenInterBrokerProtocolLessThanKafkaV2eralAclChangesForOlderProtocolVersions()
 PASSED

AclAuthorizerTest > testAuthorzeByResourceTypeSuperUserHasAccess() STARTED

AclAuthorizerTest > testAuthorzeByResourceTypeSuperUserHasAccess() PASSED

AclAuthorizerTest > testAuthorizeByResourceTypePrefixedResourceDenyDominate() 
STARTED

AclAuthorizerTest > testAuthorizeByResourceTypePrefixedResourceDenyDominate() 
PASSED

AclAuthorizerTest > testAuthorizeByResourceTypeMultipleAddAndRemove() 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

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 > 

[jira] [Created] (KAFKA-12373) Improve KafkaRaftClient handling of graceful shutdown

[Jose Armando Garcia Sancio (Jira)]

Jose Armando Garcia Sancio created KAFKA-12373:
--

 Summary: Improve KafkaRaftClient handling of graceful shutdown
 Key: KAFKA-12373
 URL: https://issues.apache.org/jira/browse/KAFKA-12373
 Project: Kafka
  Issue Type: Sub-task
  Components: replication
Reporter: Jose Armando Garcia Sancio


The current implementation simply closes the metrics group when it is closed.

When closing the KafkaRaftClient that is the leader it should perform at least 
the following steps:
 # Stop accepting new schedule append operations
 # Append to the log batches currently in the BatchAccumulator
 # Wait with a timeout for the high-watermark to reach the LEO
 # Cooperatively resign as leader from the quorum



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Created] (KAFKA-12372) Enhance TimestampCoverter to handle fields schema name to convert to Timestamp or Date

[Hoa Le (Jira)]

Hoa Le created KAFKA-12372:
--

 Summary: Enhance TimestampCoverter to handle fields schema name to 
convert to Timestamp or Date
 Key: KAFKA-12372
 URL: https://issues.apache.org/jira/browse/KAFKA-12372
 Project: Kafka
  Issue Type: Improvement
  Components: KafkaConnect
Affects Versions: 2.7.0
Reporter: Hoa Le
 Fix For: 3.0.0


Hi team,

 

Our team is having an issue of handling multiple timestamp fields in a kafka 
message, so for now if we use the 
[converter|https://github.com/apache/kafka/blob/trunk/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/TimestampConverter.java]
 then we have to add more fields in the config.

We can implement it in a generic way to check if the field.schema().name() is 
timestamp or date then we can convert it.

Please let me know if I can contribute to this.

 

Thanks,

Hoa.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[GitHub] [kafka-site] mjsax commented on pull request #333: Added documentation fix for KAFKA-12360

[GitBox]

mjsax commented on pull request #333:
URL: https://github.com/apache/kafka-site/pull/333#issuecomment-785274324


   @nicodds Thanks for the PR!
   
   We also need a second PR for https://github.com/apache/kafka that is the 
source of truth for the docs.



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[jira] [Resolved] (KAFKA-12350) document about refresh.topics.interval.seconds default value is not right

[Chia-Ping Tsai (Jira)]

 [ 
https://issues.apache.org/jira/browse/KAFKA-12350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Chia-Ping Tsai resolved KAFKA-12350.

Resolution: Fixed

> document  about refresh.topics.interval.seconds default value is not right 
> ---
>
> Key: KAFKA-12350
> URL: https://issues.apache.org/jira/browse/KAFKA-12350
> Project: Kafka
>  Issue Type: Bug
>  Components: website
>Affects Versions: 2.7.0
>Reporter: superheizai
>Assignee: Luke Chen
>Priority: Minor
> Fix For: 3.0.0
>
>
> The config, refresh.topics.interval.seconds, described in document  give the 
> defalut value 6000, ten minutes. 600 seconds or 100 minutes?



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Re: [DISCUSS] Apache Kafka 3.0.0 release

[Chia-Ping Tsai]

Thanks for taking over this hard job! +1

On 2021/02/23 08:02:09, Konstantine Karantasis  
wrote: 
> Hi all,
> 
> Given that we seem to reach an agreement that the feature release after the
> upcoming 2.8.0 will be 3.0.0, I'd like to volunteer to be the release
> manager for the Apache Kafka 3.0.0 release.
> 
> It's a major release, so I thought it'd be helpful to start planning a bit
> in advance.
> 
> If there are no objections, I'll start working on a release plan in the
> next few days.
> 
> Best,
> Konstantine
> 

Re: [DISCUSS] KIP-715: Expose Committed offset in streams

[Walker Carlson]

Thank you for the comments everyone!

I think there are a few things I can clear up in general then I will
specifically respond to each question.

First, when I say "idling" I refer to task idling. Where the stream is
intentionally not making progress. (
https://issues.apache.org/jira/browse/KAFKA-10091 is an example). This
becomes relevant if a task is waiting on one partition with no data but
that is holding up a partition with data. That would cause one just looking
at the committed offset changes to believe the task has a problem when it
is working as intended.

In light of this confusion. I plan to change tasksIdling() to `Map getTasksStatus()` this should hopefully make it more clear what
is being exposed.

TaskStatus would include: TopicPartions, TaskId, ProcessorTopology, Idling,
and State.

Boyang:

2) I think that each task should report on whatever TopicPartitions they
hold, this means a Topic Partition might get reported twice but the user
can roll those up and use the larger one when looking at the whole app.

4) If the user collects the committed offsets across all the running
clients there shouldn't be any tasks missing correct?

6) Because there is not a 1:1 mapping between Tasks and TopicPartitions I
think it is cleaner to report them separately.

Guozhang:

1) Yes, that was my original plan but it made more sense to mirror how the
consumer exposes the committed offset.

3) That is a good point. I think that we should include internal topics as
well. I think that if the topology were to evolve there should be fair
warning anyways. Maybe you can clarify what would be limited by exposing
the interior topics here? I thought a user could find them in other ways.
If it is the name we could aynomise them before exposing them.

Thank you all for your comments. If I did not respond directly to one of
your questions I updated the kip to include the details it was requesting.
I didn't not include my proposed changes mentioned earlier as I would like
to get some feedback about what to include in TaskStatus and in general.

best,
Walker

On Mon, Feb 22, 2021 at 10:20 PM Guozhang Wang  wrote:

> Hello Walker, thanks for the KIP. A few thoughts:
>
> 1) Have you considered just relying on the `KafkaStreams#metrics()` that
> includes embedded consumer metrics that have the committed offsets
> instead of adding a new API? Not advocating that this is a better approach
> but want to make sure we considered all options before we come to the "last
> resort" of adding new public interfaces.
>
> 2) The javadoc mentions "tasks assigned to this client", but the returned
> map is on partitions. I think we should make the javadoc and the return
> types consistent, either tasks or topic partitions.
>
> 3) In addition, if for 2) above we ended up with topic partitions, then
> would they include only external source topics, or also including internal
> repartition / changelog topics? I think including only external source
> topic partitions are not sufficient for your goal of tracking progress, but
> exposing internal topic names are also a big commitment here for future
> topology evolution.
>
> 4)  For "tasksIdling", I'm wondering if we can make it more general, that
> the returned value is not just a boolean, but a TaskState that can be an
> enum of "created, restoring, running, idle, closing". This could help us in
> the future to track other things like restoration efficiency and rebalance
> efficiency etc.
>
> 5) We need to clarify how is "idling" being defined here: e.g. we can
> clearly state that a task is considered idle only if 1) lag is
> increasing, indicating that there are indeed new records arrived at source,
> while committed offset is not advancing, AND 2) produced offset (imagine we
> may have punctuations that generate new data to the output topic even if
> there's no input for a while) is not advancing either.
>
>
> Guozhang
>
>
>
> On Mon, Feb 22, 2021 at 3:11 PM Boyang Chen 
> wrote:
>
> > Thanks Walker for the proposed KIP! This should definitely empower
> KStream
> > users with better visibility.
> >
> > Meanwhile I got a couple of questions/suggestions:
> >
> >
> > 1. typo "repost/report" in the motivation section.
> >
> > 2. What offsets do we report when the task is under restoration or
> > rebalancing?
> >
> > 3. IIUC, we should clearly state that our reported metrics are based off
> > locally assigned tasks for each instance.
> >
> > 4. In the meantime, what’s our strategy to report tasks that are not
> local
> > to the instance? Users would normally try to monitor all the possible
> > tasks, and it’s unfortunate we couldn’t determine whether we have lost
> > tasks. My brainstorming was whether it makes sense for the leader
> instance
> > to report the task progress as -1 for all “supposed to be running” tasks,
> > so that on the metrics collector side it could catch any missing tasks.
> >
> > 5. It seems not clear how users should use `isTaskIdling`. Why not
> report a
> > map/set for 

Re: [DISCUSS] Apache Kafka 3.0.0 release

[Bill Bejeck]

Thanks for volunteering Konstantine, +1 for me.

-Bill

On Wed, Feb 24, 2021 at 8:59 AM Ismael Juma  wrote:

> Thanks for volunteering Konstantine! +1.
>
> Ismael
>
> On Tue, Feb 23, 2021 at 12:02 AM Konstantine Karantasis <
> konstant...@confluent.io> wrote:
>
> > Hi all,
> >
> > Given that we seem to reach an agreement that the feature release after
> the
> > upcoming 2.8.0 will be 3.0.0, I'd like to volunteer to be the release
> > manager for the Apache Kafka 3.0.0 release.
> >
> > It's a major release, so I thought it'd be helpful to start planning a
> bit
> > in advance.
> >
> > If there are no objections, I'll start working on a release plan in the
> > next few days.
> >
> > Best,
> > Konstantine
> >
>

[jira] [Created] (KAFKA-12371) MirrorMaker 2.0 documentation is incorrect

[Scott Kirkpatrick (Jira)]

Scott Kirkpatrick created KAFKA-12371:
-

 Summary: MirrorMaker 2.0 documentation is incorrect
 Key: KAFKA-12371
 URL: https://issues.apache.org/jira/browse/KAFKA-12371
 Project: Kafka
  Issue Type: Bug
  Components: docs, documentation
Affects Versions: 2.7.0
Reporter: Scott Kirkpatrick


There are a few places in the official MirrorMaker 2.0 docs that are either 
confusing or incorrect. Here are a few examples I've found:
The documentation for the 'sync.group.offsets.enabled' config states that it's 
enabled by default 
[here|https://github.com/apache/kafka-site/blob/61f4707381c369a98a7a77e1a7c3a11d5983909c/27/ops.html#L802],
 but the actual source code indicates that it's disabled by default 
[here|https://github.com/apache/kafka/blob/f75efb96fae99a22eb54b5d0ef4e23b28fe8cd2d/connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorConnectorConfig.java#L185].
 I'm unsure if the intent is to have it enabled or disabled by default.

There are also some numerical typos, 
[here|https://github.com/apache/kafka-site/blob/61f4707381c369a98a7a77e1a7c3a11d5983909c/27/ops.html#L791]
 and 
[here|https://github.com/apache/kafka-site/blob/61f4707381c369a98a7a77e1a7c3a11d5983909c/27/ops.html#L793].
 These lines state that the default is 6000 seconds (and that's equal to 10 
minutes), but the actual default is 600 seconds, shown 
[here|https://github.com/apache/kafka/blob/f75efb96fae99a22eb54b5d0ef4e23b28fe8cd2d/connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorConnectorConfig.java#L145]
 and 
[here|https://github.com/apache/kafka/blob/f75efb96fae99a22eb54b5d0ef4e23b28fe8cd2d/connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorConnectorConfig.java#L152]



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Re: [DISCUSS] Apache Kafka 3.0.0 release

[Ismael Juma]

Thanks for volunteering Konstantine! +1.

Ismael

On Tue, Feb 23, 2021 at 12:02 AM Konstantine Karantasis <
konstant...@confluent.io> wrote:

> Hi all,
>
> Given that we seem to reach an agreement that the feature release after the
> upcoming 2.8.0 will be 3.0.0, I'd like to volunteer to be the release
> manager for the Apache Kafka 3.0.0 release.
>
> It's a major release, so I thought it'd be helpful to start planning a bit
> in advance.
>
> If there are no objections, I'll start working on a release plan in the
> next few days.
>
> Best,
> Konstantine
>

[jira] [Resolved] (KAFKA-12290) Adding a new topic or removing an existing topic to/from --whitelist in mirrormaker config file stops all replication

[Chris Cairns (Jira)]

 [ 
https://issues.apache.org/jira/browse/KAFKA-12290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Chris Cairns resolved KAFKA-12290.
--
Resolution: Fixed

> Adding a new topic or removing an existing topic to/from --whitelist in 
> mirrormaker config file stops all replication
> -
>
> Key: KAFKA-12290
> URL: https://issues.apache.org/jira/browse/KAFKA-12290
> Project: Kafka
>  Issue Type: Bug
>  Components: mirrormaker
>Affects Versions: 0.10.2.0
>Reporter: Chris Cairns
>Priority: Major
>  Labels: mirrormaker
>
> Looking for some assistance, not too familiar with mirrormaker.
> In our mirrormaker, adding a new topic or removing an existing topic from the 
> --whitelist in the config service file for mirrormaker stops all replication.
>  # Could I get advise on why this might be & what to check?
>  # Mirrormaker is at the target cluster
>  # Topics are manually created in both source and destination



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Re: [DISCUSS] KIP-697: Stricter parsing of addresses in configs

[Tom Bentley]

So we missed the boat for 2.8. Any interest in doing this is 3.0 (even just
adding the warning?)

Kind regards,

Tom

On Tue, Jan 19, 2021 at 12:09 PM Tom Bentley  wrote:

> Hi Gwen,
>
> Thanks for taking the time to look at it.
>
> 1. It's difficult to have a clear idea how often people supply a protocol.
> I wouldn't expect it to be common, since the documentation doesn't mention
> it. Maybe early users of Kafka still have the protocol in their configs
> (assuming it was documented differently at some point, or maybe even used,
> though I did a bit of digging and didn't find anything). I agree that the
> benefits are small but the bug mentioned in the KIP is quite nasty, so I
> feel it would be good to tidy this up.
>
> 2. In the light of 1. I think some logging in 2.8 would be a great idea.
> I've opened a PR[1] which could be merged if this KIP is accepted.
>
> Is this enough to alleviate your concerns?
>
> Kind regards,
>
> Tom
>
> [1]: https://github.com/apache/kafka/pull/9929
>
> On Thu, Jan 14, 2021 at 9:37 PM Gwen Shapira  wrote:
>
>> Sorry for being late, I just saw this. I have a concern about the
>> compatibility story:
>>
>> 1. Do we know how common use of protocol is? While this is an
>> improvement, the benefits are a bit small (IMO) and if this will break
>> a large number of installations (or will make the upgrade to 3.0 more
>> painful and therefore less likely to happen) - maybe it is't worth it.
>> 2. Should we add a PR to 2.8 that will print deprecation warnings if
>> protocol is used? This way people will at least know what is coming.
>>
>> Gwen
>>
>> On Mon, Jan 4, 2021 at 1:21 AM Tom Bentley  wrote:
>> >
>> > Hi,
>> >
>> > If there are no comments about this minor change in the next day or two
>> I
>> > will start a vote.
>> >
>> > Kind regards,
>> >
>> > Tom
>> >
>> > On Wed, Dec 9, 2020 at 6:10 PM Tom Bentley  wrote:
>> >
>> > > Hi,
>> > >
>> > > I'd like to start a discussion on a small KIP which proposes stricter
>> > > parsing of host:port addresses in various configs for Kafka 3.0:
>> > >
>> > >
>> > >
>> https://cwiki.apache.org/confluence/display/KAFKA/KIP-697%3A+Stricter+parsing+of+addresses+in+configs
>> > >
>> > > I'd be grateful for any feedback people may have.
>> > >
>> > > Kind regards,
>> > >
>> > > Tom
>> > >
>>
>>
>>
>> --
>> Gwen Shapira
>> Engineering Manager | Confluent
>> 650.450.2760 | @gwenshap
>> Follow us: Twitter | blog
>>
>>

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #507

[Apache Jenkins Server]

See 


Changes:

[github] KAFKA-12323: Set timestamp in record context when punctuate (#10170)


--
[...truncated 3.66 MB...]
ConsoleConsumerTest > groupIdsProvidedInDifferentPlacesMustMatch() STARTED

ConsoleConsumerTest > groupIdsProvidedInDifferentPlacesMustMatch() PASSED

ConsoleConsumerTest > 
shouldParseValidConsumerConfigWithAutoOffsetResetAndMatchingFromBeginning() 
STARTED

ConsoleConsumerTest > 
shouldParseValidConsumerConfigWithAutoOffsetResetAndMatchingFromBeginning() 
PASSED

ConsoleConsumerTest > shouldExitOnGroupIdAndPartitionGivenTogether() STARTED

ConsoleConsumerTest > shouldExitOnGroupIdAndPartitionGivenTogether() PASSED

ConsoleConsumerTest > shouldExitOnUnrecognizedNewConsumerOption() STARTED

ConsoleConsumerTest > shouldExitOnUnrecognizedNewConsumerOption() PASSED

ConsoleConsumerTest > 
shouldParseValidSimpleConsumerValidConfigWithNumericOffset() STARTED

ConsoleConsumerTest > 
shouldParseValidSimpleConsumerValidConfigWithNumericOffset() PASSED

ConsoleConsumerTest > 
shouldParseValidConsumerConfigWithAutoOffsetResetEarliest() STARTED

ConsoleConsumerTest > 
shouldParseValidConsumerConfigWithAutoOffsetResetEarliest() PASSED

ConsoleConsumerTest > testNoOpMessageFormatter() STARTED

ConsoleConsumerTest > testNoOpMessageFormatter() PASSED

ConsoleConsumerTest > 
shouldParseValidSimpleConsumerValidConfigWithStringOffset() STARTED

ConsoleConsumerTest > 
shouldParseValidSimpleConsumerValidConfigWithStringOffset() PASSED

ConsoleConsumerTest > testDefaultMessageFormatter() STARTED

ConsoleConsumerTest > testDefaultMessageFormatter() PASSED

ConsoleConsumerTest > testCustomPropertyShouldBePassedToConfigureMethod() 
STARTED

ConsoleConsumerTest > testCustomPropertyShouldBePassedToConfigureMethod() PASSED

ConsoleConsumerTest > shouldParseValidConsumerValidConfig() STARTED

ConsoleConsumerTest > shouldParseValidConsumerValidConfig() PASSED

ConsoleConsumerTest > shouldParseValidConsumerConfigWithNoOffsetReset() STARTED

ConsoleConsumerTest > shouldParseValidConsumerConfigWithNoOffsetReset() PASSED

GetOffsetShellParsingTest > testPartitionFilterForLowerBound() STARTED

GetOffsetShellParsingTest > testPartitionFilterForLowerBound() PASSED

GetOffsetShellParsingTest > testPartitionFilterForRange() STARTED

GetOffsetShellParsingTest > testPartitionFilterForRange() PASSED

GetOffsetShellParsingTest > [1] excludeInternal=true STARTED

GetOffsetShellParsingTest > [1] excludeInternal=true PASSED

GetOffsetShellParsingTest > [2] excludeInternal=false STARTED

GetOffsetShellParsingTest > [2] excludeInternal=false PASSED

GetOffsetShellParsingTest > testPartitionFilterForInvalidSingleIndex() STARTED

GetOffsetShellParsingTest > testPartitionFilterForInvalidSingleIndex() PASSED

GetOffsetShellParsingTest > [1] excludeInternal=true STARTED

GetOffsetShellParsingTest > [1] excludeInternal=true PASSED

GetOffsetShellParsingTest > [2] excludeInternal=false STARTED

GetOffsetShellParsingTest > [2] excludeInternal=false PASSED

GetOffsetShellParsingTest > testPartitionFilterForUpperBound() STARTED

GetOffsetShellParsingTest > testPartitionFilterForUpperBound() PASSED

GetOffsetShellParsingTest > testPartitionFilterForInvalidLowerBound() STARTED

GetOffsetShellParsingTest > testPartitionFilterForInvalidLowerBound() PASSED

GetOffsetShellParsingTest > [1] excludeInternal=true STARTED

GetOffsetShellParsingTest > [1] excludeInternal=true PASSED

GetOffsetShellParsingTest > [2] excludeInternal=false STARTED

GetOffsetShellParsingTest > [2] excludeInternal=false PASSED

GetOffsetShellParsingTest > [1] excludeInternal=true STARTED

GetOffsetShellParsingTest > [1] excludeInternal=true PASSED

GetOffsetShellParsingTest > [2] excludeInternal=false STARTED

GetOffsetShellParsingTest > [2] excludeInternal=false PASSED

GetOffsetShellParsingTest > [1] excludeInternal=true STARTED

GetOffsetShellParsingTest > [1] excludeInternal=true PASSED

GetOffsetShellParsingTest > [2] excludeInternal=false STARTED

GetOffsetShellParsingTest > [2] excludeInternal=false PASSED

GetOffsetShellParsingTest > [1] excludeInternal=true STARTED

GetOffsetShellParsingTest > [1] excludeInternal=true PASSED

GetOffsetShellParsingTest > [2] excludeInternal=false STARTED

GetOffsetShellParsingTest > [2] excludeInternal=false PASSED

GetOffsetShellParsingTest > [1] excludeInternal=true STARTED

GetOffsetShellParsingTest > [1] excludeInternal=true PASSED

GetOffsetShellParsingTest > [2] excludeInternal=false STARTED

GetOffsetShellParsingTest > [2] excludeInternal=false PASSED

GetOffsetShellParsingTest > testPartitionFilterForInvalidUpperBound() STARTED

GetOffsetShellParsingTest > testPartitionFilterForInvalidUpperBound() PASSED

GetOffsetShellParsingTest > testPartitionFilterForSingleIndex() STARTED

GetOffsetShellParsingTest > testPartitionFilterForSingleIndex() PASSED

GetOffsetShellParsingTest > [1] 

[GitHub] [kafka-site] nicodds opened a new pull request #333: Added documentation fix for KAFKA-12360

[GitBox]

nicodds opened a new pull request #333:
URL: https://github.com/apache/kafka-site/pull/333


   The fix clarify the use of max.task.idle.ms, as pointed out in 
https://issues.apache.org/jira/browse/KAFKA-12360



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Build failed in Jenkins: Kafka » kafka-2.8-jdk8 #36

[Apache Jenkins Server]

See 


Changes:

[Guozhang Wang] KAFKA-12323: Set timestamp in record context when punctuate 
(#10170)


--
[...truncated 7.21 MB...]
RequestConvertToJsonTest > testRequestDescMetrics() PASSED

RequestConvertToJsonTest > testClientInfoNode() STARTED

RequestConvertToJsonTest > testClientInfoNode() PASSED

RequestConvertToJsonTest > testRequestDesc() STARTED

RequestConvertToJsonTest > testRequestDesc() PASSED

RequestConvertToJsonTest > testRequestHeaderNode() STARTED

RequestConvertToJsonTest > testRequestHeaderNode() PASSED

MetricsTest > testUpdateJMXFilter() STARTED

MetricsTest > testUpdateJMXFilter() PASSED

MetricsTest > testGeneralBrokerTopicMetricsAreGreedilyRegistered() STARTED

MetricsTest > testGeneralBrokerTopicMetricsAreGreedilyRegistered() PASSED

MetricsTest > testLinuxIoMetrics() STARTED

MetricsTest > testLinuxIoMetrics() PASSED

MetricsTest > testMetricsReporterAfterDeletingTopic() STARTED

MetricsTest > testMetricsReporterAfterDeletingTopic() PASSED

MetricsTest > testSessionExpireListenerMetrics() STARTED

MetricsTest > testSessionExpireListenerMetrics() PASSED

MetricsTest > testBrokerTopicMetricsUnregisteredAfterDeletingTopic() STARTED

MetricsTest > testBrokerTopicMetricsUnregisteredAfterDeletingTopic() PASSED

MetricsTest > testYammerMetricsCountMetric() STARTED

MetricsTest > testYammerMetricsCountMetric() PASSED

MetricsTest > testClusterIdMetric() STARTED

MetricsTest > testClusterIdMetric() PASSED

MetricsTest > testControllerMetrics() STARTED

MetricsTest > testControllerMetrics() PASSED

MetricsTest > testWindowsStyleTagNames() STARTED

MetricsTest > testWindowsStyleTagNames() PASSED

MetricsTest > testBrokerStateMetric() STARTED

MetricsTest > testBrokerStateMetric() PASSED

MetricsTest > testBrokerTopicMetricsBytesInOut() STARTED

MetricsTest > testBrokerTopicMetricsBytesInOut() PASSED

MetricsTest > testJMXFilter() STARTED

MetricsTest > testJMXFilter() 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

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@effe9e2, value = [B@33ff34a4), 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@effe9e2, value = [B@33ff34a4), 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@71f3ee35, value = [B@58bc9190), 

Re: [DISCUSS] KIP-707: The future of KafkaFuture

[Tom Bentley]

If the next release is going to be Kafka 3.0, as seems to be the case, it
would be a great time to decide whether and what we're doing with this API.
So I'd be grateful for any feedback people might have.

Many thanks,

Tom

On Tue, Feb 2, 2021 at 10:40 AM Tom Bentley  wrote:

> I've previously discounted the possibility of an "Admin2" client, but
> seeing the recent discussions on the thread for KIP-706, I wonder whether
> this current proposal in KIP-707 would benefit from a bit more
> discussion... I think there are broadly two approaches to evolving the
> Admin client API to use CompletionStage directly (rather than what's
> currently proposed in KIP-707):
>
> The simpler option, from a development point of view, would be to
> introduce an alternative/parallel set of classes for each of the existing
> result classes. E.g. ListTopicsOutcome which was the same as
> ListTopicsResult, but using CompletionStage rather than KafkaFuture. Adding
> methods to the existing Admin interface would require coming up with
> synonym method names for every API call, and probably half of the API being
> deprecated (if not immediately then in the long run). It would be cleaner
> to have a whole new interface, let's call it Manager, using the same method
> names. The existing Admin client implementation would then wrap a Manager
> instance, and the existing Result classes could have a constructor
> parameter of their corresponding Outcome instance which wrapped the
> CompletionStages with KafkaFutures. The Options classes would be unchanged.
> From a users point of view migrating to the new Manager client would mostly
> be a matter of changing class names and adding a `.toCompletionStage()` to
> those places where they were calling KafkaFuture.get()/getNow() (and even
> this could be avoided if we used CompletableFuture rather than
> CompletionStage in the Outcome class APIs). In the long run Admin would be
> removed and we'd be left with the minor annoyance of having a client called
> Manager in a package called admin.
>
> The more involved version would do a similar refactoring, but within a
> different package. If we stuck with the Admin and Result class names the
> users experience of migrating their codebase would be limited to changing
> import statements and the same additions of `.toCompletionStage()`. On the
> implementation side it would force us to duplicate all the Options classes
> and also have a way of converting old Options instances to their new
> equivalents so that the old Admin implementation could delegate to the new
> one. The main benefit of this approach seems to be the slightly easier
> experience for people porting their code to the new client.
>
> In doing either of these much more significant refactorings there would
> also be the opportunity to omit the current Admin API's deprecated methods
> and classes from the new API.
>
> Do we think this is worth biting off in order to have more long term
> consistency between the Admin, Producer and consumer APIs?
>
> Kind regards,
>
> Tom
>
> On Fri, Jan 22, 2021 at 3:02 PM Tom Bentley  wrote:
>
>> Hi,
>>
>> Following a recent discussion on a PR[1], I've written KIP-707 to
>> establish what should be done to improve the API of KafkaFuture.
>> If you have the time, your comments would be most welcome, as some of the
>> rejected alternatives are not unreasonable.
>>
>>
>> https://cwiki.apache.org/confluence/display/KAFKA/KIP-707%3A+The+future+of+KafkaFuture
>>
>> Many thanks,
>>
>> Tom
>>
>> [1]: https://github.com/apache/kafka/pull/9878
>>
>

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #564

[Apache Jenkins Server]

See 


Changes:

[github] KAFKA-12323: Set timestamp in record context when punctuate (#10170)


--
[...truncated 7.33 MB...]

TransactionsTest > testReadCommittedConsumerShouldNotSeeUndecidedData() STARTED

TransactionsTest > testReadCommittedConsumerShouldNotSeeUndecidedData() PASSED

TransactionsTest > testSendOffsetsToTransactionTimeout() STARTED

TransactionsTest > testSendOffsetsToTransactionTimeout() PASSED

TransactionsTest > testFailureToFenceEpoch() STARTED

TransactionsTest > testFailureToFenceEpoch() PASSED

TransactionsTest > testFencingOnSend() STARTED

TransactionsTest > testFencingOnSend() PASSED

TransactionsTest > testFencingOnCommit() STARTED

TransactionsTest > testFencingOnCommit() PASSED

TransactionsTest > testAbortTransactionTimeout() STARTED

TransactionsTest > testAbortTransactionTimeout() PASSED

TransactionsTest > testMultipleMarkersOneLeader() STARTED

TransactionsTest > testMultipleMarkersOneLeader() PASSED

TransactionsTest > testCommitTransactionTimeout() STARTED

TransactionsTest > testCommitTransactionTimeout() PASSED

SaslClientsWithInvalidCredentialsTest > 
testTransactionalProducerWithAuthenticationFailure() STARTED

SaslClientsWithInvalidCredentialsTest > 
testTransactionalProducerWithAuthenticationFailure() PASSED

SaslClientsWithInvalidCredentialsTest > 
testManualAssignmentConsumerWithAuthenticationFailure() STARTED

SaslClientsWithInvalidCredentialsTest > 
testManualAssignmentConsumerWithAuthenticationFailure() PASSED

SaslClientsWithInvalidCredentialsTest > 
testConsumerGroupServiceWithAuthenticationSuccess() STARTED

SaslClientsWithInvalidCredentialsTest > 
testConsumerGroupServiceWithAuthenticationSuccess() PASSED

SaslClientsWithInvalidCredentialsTest > testProducerWithAuthenticationFailure() 
STARTED

SaslClientsWithInvalidCredentialsTest > testProducerWithAuthenticationFailure() 
PASSED

SaslClientsWithInvalidCredentialsTest > 
testConsumerGroupServiceWithAuthenticationFailure() STARTED

SaslClientsWithInvalidCredentialsTest > 
testConsumerGroupServiceWithAuthenticationFailure() PASSED

SaslClientsWithInvalidCredentialsTest > 
testManualAssignmentConsumerWithAutoCommitDisabledWithAuthenticationFailure() 
STARTED

SaslClientsWithInvalidCredentialsTest > 
testManualAssignmentConsumerWithAutoCommitDisabledWithAuthenticationFailure() 
PASSED

SaslClientsWithInvalidCredentialsTest > 
testKafkaAdminClientWithAuthenticationFailure() STARTED

SaslClientsWithInvalidCredentialsTest > 
testKafkaAdminClientWithAuthenticationFailure() PASSED

SaslClientsWithInvalidCredentialsTest > testConsumerWithAuthenticationFailure() 
STARTED

SaslClientsWithInvalidCredentialsTest > testConsumerWithAuthenticationFailure() 
PASSED

UserClientIdQuotaTest > testProducerConsumerOverrideLowerQuota() STARTED

UserClientIdQuotaTest > testProducerConsumerOverrideLowerQuota() PASSED

UserClientIdQuotaTest > testProducerConsumerOverrideUnthrottled() STARTED

UserClientIdQuotaTest > testProducerConsumerOverrideUnthrottled() PASSED

UserClientIdQuotaTest > testThrottledProducerConsumer() STARTED

UserClientIdQuotaTest > testThrottledProducerConsumer() PASSED

UserClientIdQuotaTest > testQuotaOverrideDelete() STARTED

UserClientIdQuotaTest > testQuotaOverrideDelete() PASSED

UserClientIdQuotaTest > testThrottledRequest() STARTED

UserClientIdQuotaTest > testThrottledRequest() PASSED

ZooKeeperClientTest > testZNodeChangeHandlerForDataChange() STARTED

ZooKeeperClientTest > testZNodeChangeHandlerForDataChange() PASSED

ZooKeeperClientTest > testZooKeeperSessionStateMetric() STARTED

ZooKeeperClientTest > testZooKeeperSessionStateMetric() PASSED

ZooKeeperClientTest > testExceptionInBeforeInitializingSession() STARTED

ZooKeeperClientTest > testExceptionInBeforeInitializingSession() PASSED

ZooKeeperClientTest > testGetChildrenExistingZNode() STARTED

ZooKeeperClientTest > testGetChildrenExistingZNode() PASSED

ZooKeeperClientTest > testConnection() STARTED

ZooKeeperClientTest > testConnection() PASSED

ZooKeeperClientTest > testZNodeChangeHandlerForCreation() STARTED

ZooKeeperClientTest > testZNodeChangeHandlerForCreation() PASSED

ZooKeeperClientTest > testGetAclExistingZNode() STARTED

ZooKeeperClientTest > testGetAclExistingZNode() PASSED

ZooKeeperClientTest > testSessionExpiryDuringClose() STARTED

ZooKeeperClientTest > testSessionExpiryDuringClose() PASSED

ZooKeeperClientTest > testReinitializeAfterAuthFailure() STARTED

ZooKeeperClientTest > testReinitializeAfterAuthFailure() PASSED

ZooKeeperClientTest > testSetAclNonExistentZNode() STARTED

ZooKeeperClientTest > testSetAclNonExistentZNode() PASSED

ZooKeeperClientTest > testConnectionLossRequestTermination() STARTED

ZooKeeperClientTest > testConnectionLossRequestTermination() PASSED

ZooKeeperClientTest > testExistsNonExistentZNode() STARTED

ZooKeeperClientTest > testExistsNonExistentZNode() PASSED

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #538

[Apache Jenkins Server]

See 


Changes:

[github] KAFKA-12323: Set timestamp in record context when punctuate (#10170)


--
[...truncated 3.67 MB...]
SocketServerTest > testNoOpAction() STARTED

SocketServerTest > testNoOpAction() PASSED

SocketServerTest > simpleRequest() STARTED

SocketServerTest > simpleRequest() PASSED

SocketServerTest > 
testSendActionResponseWithThrottledChannelWhereThrottlingInProgress() STARTED

SocketServerTest > 
testSendActionResponseWithThrottledChannelWhereThrottlingInProgress() PASSED

SocketServerTest > testIdleConnection() STARTED

SocketServerTest > testIdleConnection() PASSED

SocketServerTest > remoteCloseWithoutBufferedReceives() STARTED

SocketServerTest > remoteCloseWithoutBufferedReceives() PASSED

SocketServerTest > remoteCloseWithCompleteAndIncompleteBufferedReceives() 
STARTED

SocketServerTest > remoteCloseWithCompleteAndIncompleteBufferedReceives() PASSED

SocketServerTest > testZeroMaxConnectionsPerIp() STARTED

SocketServerTest > testZeroMaxConnectionsPerIp() PASSED

SocketServerTest > testClientInformationWithLatestApiVersionsRequest() STARTED

SocketServerTest > testClientInformationWithLatestApiVersionsRequest() PASSED

SocketServerTest > testMetricCollectionAfterShutdown() STARTED

SocketServerTest > testMetricCollectionAfterShutdown() PASSED

SocketServerTest > testSessionPrincipal() STARTED

SocketServerTest > testSessionPrincipal() PASSED

SocketServerTest > configureNewConnectionException() STARTED

SocketServerTest > configureNewConnectionException() PASSED

SocketServerTest > testSaslReauthenticationFailureWithKip152SaslAuthenticate() 
STARTED

SocketServerTest > testSaslReauthenticationFailureWithKip152SaslAuthenticate() 
PASSED

SocketServerTest > testMaxConnectionsPerIpOverrides() STARTED

SocketServerTest > testMaxConnectionsPerIpOverrides() PASSED

SocketServerTest > processNewResponseException() STARTED

SocketServerTest > processNewResponseException() PASSED

SocketServerTest > remoteCloseWithIncompleteBufferedReceive() STARTED

SocketServerTest > remoteCloseWithIncompleteBufferedReceive() PASSED

SocketServerTest > testStagedListenerShutdownWhenConnectionQueueIsFull() STARTED

SocketServerTest > testStagedListenerShutdownWhenConnectionQueueIsFull() PASSED

SocketServerTest > testStagedListenerStartup() STARTED

SocketServerTest > testStagedListenerStartup() PASSED

SocketServerTest > testConnectionRateLimit() STARTED

SocketServerTest > testConnectionRateLimit() PASSED

SocketServerTest > testConnectionRatePerIp() STARTED

SocketServerTest > testConnectionRatePerIp() PASSED

SocketServerTest > processCompletedSendException() STARTED

SocketServerTest > processCompletedSendException() PASSED

SocketServerTest > processDisconnectedException() STARTED

SocketServerTest > processDisconnectedException() PASSED

SocketServerTest > closingChannelWithBufferedReceives() STARTED

SocketServerTest > closingChannelWithBufferedReceives() PASSED

SocketServerTest > sendCancelledKeyException() STARTED

SocketServerTest > sendCancelledKeyException() PASSED

SocketServerTest > processCompletedReceiveException() STARTED

SocketServerTest > processCompletedReceiveException() PASSED

SocketServerTest > testControlPlaneAsPrivilegedListener() STARTED

SocketServerTest > testControlPlaneAsPrivilegedListener() PASSED

SocketServerTest > closingChannelSendFailure() STARTED

SocketServerTest > closingChannelSendFailure() PASSED

SocketServerTest > idleExpiryWithBufferedReceives() STARTED

SocketServerTest > idleExpiryWithBufferedReceives() PASSED

SocketServerTest > testSocketsCloseOnShutdown() STARTED

SocketServerTest > testSocketsCloseOnShutdown() PASSED

SocketServerTest > 
testNoOpActionResponseWithThrottledChannelWhereThrottlingAlreadyDone() STARTED

SocketServerTest > 
testNoOpActionResponseWithThrottledChannelWhereThrottlingAlreadyDone() PASSED

SocketServerTest > pollException() STARTED

SocketServerTest > pollException() PASSED

SocketServerTest > closingChannelWithBufferedReceivesFailedSend() STARTED

SocketServerTest > closingChannelWithBufferedReceivesFailedSend() PASSED

SocketServerTest > remoteCloseWithBufferedReceives() STARTED

SocketServerTest > remoteCloseWithBufferedReceives() PASSED

SocketServerTest > testThrottledSocketsClosedOnShutdown() STARTED

SocketServerTest > testThrottledSocketsClosedOnShutdown() PASSED

SocketServerTest > closingChannelWithCompleteAndIncompleteBufferedReceives() 
STARTED

SocketServerTest > closingChannelWithCompleteAndIncompleteBufferedReceives() 
PASSED

SocketServerTest > testInterBrokerListenerAsPrivilegedListener() STARTED

SocketServerTest > testInterBrokerListenerAsPrivilegedListener() PASSED

SocketServerTest > testSslSocketServer() STARTED

SocketServerTest > testSslSocketServer() PASSED

SocketServerTest > testDisabledRequestIsRejected() STARTED

SocketServerTest > testDisabledRequestIsRejected()