Re: [DISCUSS] Apache Kafka 2.6.2 release

[Luke Chen]

Hi Ismael & Sophie,
Sorry, after some investigation, I think this might not be a defect. To
work with the project with a specific scala version, user might need to use
the same version as the project used. This issue also happened on other
projects using scala, ex: Spark. ref: https://stackoverflow.com/a/61677956.

So, you can continue to cut the rc.

Thank you very much.
Luke

On Wed, Feb 10, 2021 at 11:19 AM Luke Chen  wrote:

> I just saw the defect KAFKA-12312
> , so I brought it to
> your attention.
> Do you think it's not a compatibility issue? If not, I think we don't need
> to cherry-pick the fix.
>
> Thanks.
> Luke
>
> On Wed, Feb 10, 2021 at 11:16 AM Ismael Juma  wrote:
>
>> It's a perf improvement, there was no regression. I think Luke needs to be
>> clearer how this impacts users. Luke, are you referring to cases where
>> someone runs the broker in an embedded scenario (eg tests)?
>>
>> Ismael
>>
>> On Tue, Feb 9, 2021, 6:50 PM Sophie Blee-Goldman 
>> wrote:
>>
>> > What do you think Ismael? I agreed initially because I saw the commit
>> > message says it fixes a performance regression. But admittedly I don't
>> have
>> > much context on this particular issue
>> >
>> > If it's low risk then I don't have a strong argument against including
>> it.
>> > However
>> > I aim to cut the rc tomorrow or Thursday, and if it hasn't been
>> > cherrypicked by then
>> > I won't block the release on it.
>> >
>> > On Tue, Feb 9, 2021 at 4:53 PM Luke Chen  wrote:
>> >
>> > > Hi Ismael,
>> > > Yes, I agree it's like an improvement, not a bug. I don't insist on
>> > putting
>> > > it into 2.6, just want to bring it to your attention.
>> > > In my opinion, this issue will block users who adopt the scala 2.13.4
>> or
>> > > later to use Kafka 2.6.
>> > > So if we still have time, we can consider to cherry-pick the fix into
>> 2.6
>> > > and 2.7.
>> > >
>> > > What do you think?
>> > >
>> > > Thank you.
>> > > Luke
>> > >
>> > > On Wed, Feb 10, 2021 at 3:24 AM Ismael Juma 
>> wrote:
>> > >
>> > > > Can you elaborate why this needs to be in 2.6? Seems like an
>> > improvement
>> > > > versus a critical bug fix.
>> > > >
>> > > > Ismael
>> > > >
>> > > > On Mon, Feb 8, 2021 at 6:39 PM Luke Chen  wrote:
>> > > >
>> > > > > Hi Sophie,
>> > > > > I found there is 1 issue that should be cherry-picked into 2.6 and
>> > 2.7
>> > > > > branches: KAFKA-12312 <
>> > > https://issues.apache.org/jira/browse/KAFKA-12312
>> > > > >.
>> > > > > Simply put, *Scala* *2.13.4* is released at the end of 2020, and
>> we
>> > > > > upgraded to it and fixed some compatible issues on this PR
>> > > > > , more specifically,
>> it's
>> > > > here
>> > > > > <
>> > > > >
>> > > >
>> > >
>> >
>> https://github.com/apache/kafka/pull/9643/files#diff-fda3fb44e69a19600913bd951431fb0035996c76325b1c1d84d6f34bec281205R292
>> > > > > >
>> > > > > .
>> > > > > We only merged this fix on *trunk*(which will be on 2.8), but we
>> > didn't
>> > > > > tell users (or we didn't know there'll be compatible issues) not
>> to
>> > > adopt
>> > > > > the latest *Scala* *2.13.4*.
>> > > > >
>> > > > > Therefore, I think we should cherry-pick this fix into 2.6 and 2.7
>> > > > > branches. What do you think?
>> > > > >
>> > > > > Thank you.
>> > > > > Luke
>> > > > >
>> > > > >
>> > > > >
>> > > > >
>> > > > >
>> > > > > On Tue, Feb 9, 2021 at 3:10 AM Sophie Blee-Goldman <
>> > > sop...@confluent.io>
>> > > > > wrote:
>> > > > >
>> > > > > > Hey all,
>> > > > > >
>> > > > > > Since all outstanding bugfixes seem to have made their way over
>> to
>> > > the
>> > > > > 2.6
>> > > > > > branch by now, I plan to move ahead with cutting an RC. As
>> always,
>> > > > please
>> > > > > > let me know if you uncover and critical or blocker bugs that
>> affect
>> > > 2.6
>> > > > > >
>> > > > > > Thanks!
>> > > > > > Sophie
>> > > > > >
>> > > > > > On Thu, Jan 28, 2021 at 9:25 AM John Roesler <
>> vvcep...@apache.org>
>> > > > > wrote:
>> > > > > >
>> > > > > > > Thanks so much for stepping up, Sophie!
>> > > > > > >
>> > > > > > > I'm +1
>> > > > > > >
>> > > > > > > -John
>> > > > > > >
>> > > > > > > On Wed, 2021-01-27 at 17:59 -0500, Bill Bejeck wrote:
>> > > > > > > > Thanks for taking this on Sophie. +1
>> > > > > > > >
>> > > > > > > > Bill
>> > > > > > > >
>> > > > > > > > On Wed, Jan 27, 2021 at 5:59 PM Ismael Juma <
>> ism...@juma.me.uk
>> > >
>> > > > > wrote:
>> > > > > > > >
>> > > > > > > > > Thanks Sophie! +1
>> > > > > > > > >
>> > > > > > > > > Ismael
>> > > > > > > > >
>> > > > > > > > > On Wed, Jan 27, 2021 at 2:45 PM Sophie Blee-Goldman <
>> > > > > > > sop...@confluent.io>
>> > > > > > > > > wrote:
>> > > > > > > > >
>> > > > > > > > > > Hi all,
>> > > > > > > > > >
>> > > > > > > > > > I'd like to volunteer as release manager for a 2.6.2
>> > release.
>> > > > > This
>> > > > > > is
>> > > > > > > > > being
>> > > > > > > > > > accelerated
>> > > > > > > > > > to

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

[Apache Jenkins Server]

See 


Changes:

[github] Fill in the 2.8 release note for Authorizer (#9865)


--
[...truncated 3.60 MB...]

ControllerEventManagerTest > testMetricsCleanedOnClose() PASSED

ControllerChannelManagerTest > 
testStopReplicaRequestWithAlreadyDefinedDeletedPartition() STARTED

ControllerChannelManagerTest > 
testStopReplicaRequestWithAlreadyDefinedDeletedPartition() PASSED

ControllerChannelManagerTest > testUpdateMetadataInterBrokerProtocolVersion() 
STARTED

ControllerChannelManagerTest > testUpdateMetadataInterBrokerProtocolVersion() 
PASSED

ControllerChannelManagerTest > testLeaderAndIsrRequestIsNew() STARTED

ControllerChannelManagerTest > testLeaderAndIsrRequestIsNew() PASSED

ControllerChannelManagerTest > 
testStopReplicaRequestsWhileTopicQueuedForDeletion() STARTED

ControllerChannelManagerTest > 
testStopReplicaRequestsWhileTopicQueuedForDeletion() PASSED

ControllerChannelManagerTest > 
testLeaderAndIsrRequestSentToLiveOrShuttingDownBrokers() STARTED

ControllerChannelManagerTest > 
testLeaderAndIsrRequestSentToLiveOrShuttingDownBrokers() PASSED

ControllerChannelManagerTest > testStopReplicaInterBrokerProtocolVersion() 
STARTED

ControllerChannelManagerTest > testStopReplicaInterBrokerProtocolVersion() 
PASSED

ControllerChannelManagerTest > 
testStopReplicaSentOnlyToLiveAndShuttingDownBrokers() STARTED

ControllerChannelManagerTest > 
testStopReplicaSentOnlyToLiveAndShuttingDownBrokers() PASSED

ControllerChannelManagerTest > testStopReplicaGroupsByBroker() STARTED

ControllerChannelManagerTest > testStopReplicaGroupsByBroker() PASSED

ControllerChannelManagerTest > 
testUpdateMetadataDoesNotIncludePartitionsWithoutLeaderAndIsr() STARTED

ControllerChannelManagerTest > 
testUpdateMetadataDoesNotIncludePartitionsWithoutLeaderAndIsr() PASSED

ControllerChannelManagerTest > testMixedDeleteAndNotDeleteStopReplicaRequests() 
STARTED

ControllerChannelManagerTest > testMixedDeleteAndNotDeleteStopReplicaRequests() 
PASSED

ControllerChannelManagerTest > testLeaderAndIsrInterBrokerProtocolVersion() 
STARTED

ControllerChannelManagerTest > testLeaderAndIsrInterBrokerProtocolVersion() 
PASSED

ControllerChannelManagerTest > testUpdateMetadataRequestSent() STARTED

ControllerChannelManagerTest > testUpdateMetadataRequestSent() PASSED

ControllerChannelManagerTest > testUpdateMetadataRequestDuringTopicDeletion() 
STARTED

ControllerChannelManagerTest > testUpdateMetadataRequestDuringTopicDeletion() 
PASSED

ControllerChannelManagerTest > 
testUpdateMetadataIncludesLiveOrShuttingDownBrokers() STARTED

ControllerChannelManagerTest > 
testUpdateMetadataIncludesLiveOrShuttingDownBrokers() PASSED

ControllerChannelManagerTest > testStopReplicaRequestSent() STARTED

ControllerChannelManagerTest > testStopReplicaRequestSent() PASSED

ControllerChannelManagerTest > 
testStopReplicaRequestsWhileTopicDeletionStarted() STARTED

ControllerChannelManagerTest > 
testStopReplicaRequestsWhileTopicDeletionStarted() PASSED

ControllerChannelManagerTest > testLeaderAndIsrRequestSent() STARTED

ControllerChannelManagerTest > testLeaderAndIsrRequestSent() PASSED

ControllerChannelManagerTest > 
testStopReplicaRequestWithoutDeletePartitionWhileTopicDeletionStarted() STARTED

ControllerChannelManagerTest > 
testStopReplicaRequestWithoutDeletePartitionWhileTopicDeletionStarted() PASSED

FeatureZNodeTest > testDecodeFailOnInvalidFeatures() STARTED

FeatureZNodeTest > testDecodeFailOnInvalidFeatures() PASSED

FeatureZNodeTest > testEncodeDecode() STARTED

FeatureZNodeTest > testEncodeDecode() PASSED

FeatureZNodeTest > testDecodeSuccess() STARTED

FeatureZNodeTest > testDecodeSuccess() PASSED

FeatureZNodeTest > testDecodeFailOnInvalidVersionAndStatus() STARTED

FeatureZNodeTest > testDecodeFailOnInvalidVersionAndStatus() PASSED

ExtendedAclStoreTest > shouldHaveCorrectPaths() STARTED

ExtendedAclStoreTest > shouldHaveCorrectPaths() PASSED

ExtendedAclStoreTest > shouldRoundTripChangeNode() STARTED

ExtendedAclStoreTest > shouldRoundTripChangeNode() PASSED

ExtendedAclStoreTest > shouldThrowFromEncodeOnLiteral() STARTED

ExtendedAclStoreTest > shouldThrowFromEncodeOnLiteral() PASSED

ExtendedAclStoreTest > shouldThrowIfConstructedWithLiteral() STARTED

ExtendedAclStoreTest > shouldThrowIfConstructedWithLiteral() PASSED

ExtendedAclStoreTest > shouldWriteChangesToTheWritePath() STARTED

ExtendedAclStoreTest > shouldWriteChangesToTheWritePath() PASSED

ExtendedAclStoreTest > shouldHaveCorrectPatternType() STARTED

ExtendedAclStoreTest > shouldHaveCorrectPatternType() 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 = [11

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

[Apache Jenkins Server]

See 


Changes:

[github] Fill in the 2.8 release note for Authorizer (#9865)


--
[...truncated 3.60 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

ZooKeeperClientTest

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

[Apache Jenkins Server]

See 


Changes:

[github] Fill in the 2.8 release note for Authorizer (#9865)


--
[...truncated 3.61 MB...]

AclAuthorizerTest > testTopicAcl() STARTED

AclAuthorizerTest > testTopicAcl() PASSED

AclAuthorizerTest > testSuperUserHasAccess() STARTED

AclAuthorizerTest > testSuperUserHasAccess() PASSED

AclAuthorizerTest > testDeleteAclOnPrefixedResource() STARTED

AclAuthorizerTest > testDeleteAclOnPrefixedResource() PASSED

AclAuthorizerTest > testDenyTakesPrecedence() STARTED

AclAuthorizerTest > testDenyTakesPrecedence() PASSED

AclAuthorizerTest > 
testAuthorizeByResourceTypeIsolationUnrelatedDenyWontDominateAllow() STARTED

AclAuthorizerTest > 
testAuthorizeByResourceTypeIsolationUnrelatedDenyWontDominateAllow() PASSED

AclAuthorizerTest > testSingleCharacterResourceAcls() STARTED

AclAuthorizerTest > testSingleCharacterResourceAcls() PASSED

AclAuthorizerTest > testNoAclFoundOverride() STARTED

AclAuthorizerTest > testNoAclFoundOverride() PASSED

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 > test

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

[Apache Jenkins Server]

See 


Changes:

[Rajini Sivaram] Fill in the 2.8 release note for Authorizer (#9865)


--
[...truncated 3.59 MB...]
AclAuthorizerTest > 
testAuthorizeByResourceTypeIsolationUnrelatedDenyWontDominateAllow() PASSED

AclAuthorizerTest > testSingleCharacterResourceAcls() STARTED

AclAuthorizerTest > testSingleCharacterResourceAcls() PASSED

AclAuthorizerTest > testNoAclFoundOverride() STARTED

AclAuthorizerTest > testNoAclFoundOverride() PASSED

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

Authoriz

[jira] [Created] (KAFKA-12320) Provide JSON vulnerability data

[Shivam Sandbhor (Jira)]

Shivam Sandbhor created KAFKA-12320:
---

 Summary: Provide JSON vulnerability data 
 Key: KAFKA-12320
 URL: https://issues.apache.org/jira/browse/KAFKA-12320
 Project: Kafka
  Issue Type: Improvement
  Components: documentation
Reporter: Shivam Sandbhor


The vulnerability information at [https://kafka.apache.org/cve-list] is 
provided only via html. To consume this data the consumer needs to write an 
html scraper, like at https://github.com/nexB/vulnerablecode/pull/342

It would be helpful to get the data in a structured format such as  YAML .



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

Jenkins build is back to normal : Kafka » kafka-2.3-jdk8 #17

[Apache Jenkins Server]

See 

[jira] [Created] (KAFKA-12321) the comparison function for uuid type should be 'equals' rather than '=='

[Chia-Ping Tsai (Jira)]

Chia-Ping Tsai created KAFKA-12321:
--

 Summary: the comparison function for uuid type should be 'equals' 
rather than '=='
 Key: KAFKA-12321
 URL: https://issues.apache.org/jira/browse/KAFKA-12321
 Project: Kafka
  Issue Type: Bug
Reporter: Chia-Ping Tsai


trunk:
{code:java}
if (this.taggedUuid != Uuid.fromString("H3KKO4NTRPaCWtEmm3vW7A"))
{code}

expected:
{code:java}
if (!this.taggedUuid.equals(Uuid.fromString("H3KKO4NTRPaCWtEmm3vW7A")))
{code}



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

[jira] [Created] (KAFKA-12322) Why https://downloads.apache.org/kafka/ it doesnot download older version only 2.7.0 and 2.6.1 ,is there any changes done ?

[suman tripathi (Jira)]

suman tripathi created KAFKA-12322:
--

 Summary: Why https://downloads.apache.org/kafka/  it doesnot 
download older version only 2.7.0 and 2.6.1 ,is there any changes done ?
 Key: KAFKA-12322
 URL: https://issues.apache.org/jira/browse/KAFKA-12322
 Project: Kafka
  Issue Type: Bug
Reporter: suman tripathi






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

Apply for KIP permission

[Nirvana]

Apply for KIP permission,  My account name is 1572139390??  Thrank you !

I submitted a patch , https://github.com/apache/kafka/pull/9870

Apply for KIP permission

[Nirvana]

Apply for KIP permission,  My account name is 1572139390??  Thrank 
you !

Re: Apply for KIP permission

[Bill Bejeck]

You're all set now.

Thanks for your interest in Apache Kafka!

-Bill

On Wed, Feb 10, 2021 at 10:48 AM Nirvana <1572139...@qq.com> wrote:

> Apply for KIP permission,  My account name is 1572139390！
> Thrank you !

Jenkins build is back to normal : Kafka » kafka-2.5-jdk8 #39

[Apache Jenkins Server]

See 

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

[Apache Jenkins Server]

See 


Changes:

[github] MINOR: KafkaBroker.brokerState should be volatile instead of 
AtomicReference (#10080)


--
[...truncated 3.58 MB...]

SocketServerTest > remoteCloseWithIncompleteBufferedReceive() STARTED

SocketServerTest > remoteCloseWithIncompleteBufferedReceive() PASSED

SocketServerTest > testStagedListenerShutdownWhenConnectionQueueIsFull() STARTED

SocketServerTest > testStagedListenerShutdownWhenConnectionQueueIsFull() PASSED

SocketServerTest > testStagedListenerStartup() STARTED

SocketServerTest > testStagedListenerStartup() PASSED

SocketServerTest > testConnectionRateLimit() STARTED

SocketServerTest > testConnectionRateLimit() PASSED

SocketServerTest > testConnectionRatePerIp() STARTED

SocketServerTest > testConnectionRatePerIp() PASSED

SocketServerTest > processCompletedSendException() STARTED

SocketServerTest > processCompletedSendException() PASSED

SocketServerTest > processDisconnectedException() STARTED

SocketServerTest > processDisconnectedException() PASSED

SocketServerTest > closingChannelWithBufferedReceives() STARTED

SocketServerTest > closingChannelWithBufferedReceives() PASSED

SocketServerTest > sendCancelledKeyException() STARTED

SocketServerTest > sendCancelledKeyException() PASSED

SocketServerTest > processCompletedReceiveException() STARTED

SocketServerTest > processCompletedReceiveException() PASSED

SocketServerTest > testControlPlaneAsPrivilegedListener() STARTED

SocketServerTest > testControlPlaneAsPrivilegedListener() PASSED

SocketServerTest > closingChannelSendFailure() STARTED

SocketServerTest > closingChannelSendFailure() PASSED

SocketServerTest > idleExpiryWithBufferedReceives() STARTED

SocketServerTest > idleExpiryWithBufferedReceives() PASSED

SocketServerTest > testSocketsCloseOnShutdown() STARTED

SocketServerTest > testSocketsCloseOnShutdown() PASSED

SocketServerTest > 
testNoOpActionResponseWithThrottledChannelWhereThrottlingAlreadyDone() STARTED

SocketServerTest > 
testNoOpActionResponseWithThrottledChannelWhereThrottlingAlreadyDone() PASSED

SocketServerTest > pollException() STARTED

SocketServerTest > pollException() PASSED

SocketServerTest > closingChannelWithBufferedReceivesFailedSend() STARTED

SocketServerTest > closingChannelWithBufferedReceivesFailedSend() PASSED

SocketServerTest > remoteCloseWithBufferedReceives() STARTED

SocketServerTest > remoteCloseWithBufferedReceives() PASSED

SocketServerTest > testThrottledSocketsClosedOnShutdown() STARTED

SocketServerTest > testThrottledSocketsClosedOnShutdown() PASSED

SocketServerTest > closingChannelWithCompleteAndIncompleteBufferedReceives() 
STARTED

SocketServerTest > closingChannelWithCompleteAndIncompleteBufferedReceives() 
PASSED

SocketServerTest > testInterBrokerListenerAsPrivilegedListener() STARTED

SocketServerTest > testInterBrokerListenerAsPrivilegedListener() PASSED

SocketServerTest > testSslSocketServer() STARTED

SocketServerTest > testSslSocketServer() PASSED

SocketServerTest > testDisabledRequestIsRejected() STARTED

SocketServerTest > testDisabledRequestIsRejected() PASSED

SocketServerTest > tooBigRequestIsRejected() STARTED

SocketServerTest > tooBigRequestIsRejected() PASSED

SocketServerTest > 
testNoOpActionResponseWithThrottledChannelWhereThrottlingInProgress() STARTED

SocketServerTest > 
testNoOpActionResponseWithThrottledChannelWhereThrottlingInProgress() PASSED

DynamicConnectionQuotaTest > testDynamicConnectionQuota() STARTED

DynamicConnectionQuotaTest > testDynamicConnectionQuota() PASSED

DynamicConnectionQuotaTest > testDynamicListenerConnectionQuota() STARTED

DynamicConnectionQuotaTest > testDynamicListenerConnectionQuota() PASSED

DynamicConnectionQuotaTest > testDynamicListenerConnectionCreationRateQuota() 
STARTED

DynamicConnectionQuotaTest > testDynamicListenerConnectionCreationRateQuota() 
PASSED

DynamicConnectionQuotaTest > testDynamicIpConnectionRateQuota() STARTED

DynamicConnectionQuotaTest > testDynamicIpConnectionRateQuota() PASSED

DefaultMessageFormatterTest > [1] name=print nothing, 
record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, 
offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value 
size = 0, headers = RecordHeaders(headers = [RecordHeader(key = h1, value = 
[118, 49]), RecordHeader(key = h2, value = [118, 50])], isReadOnly = false), 
key = [B@68f17a6d, value = [B@5bfa4a0f), 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@68f17a6d, value = [B@5bfa4a0f), properti

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

[Apache Jenkins Server]

See 


Changes:

[github] MINOR: KafkaBroker.brokerState should be volatile instead of 
AtomicReference (#10080)


--
[...truncated 3.60 MB...]

ControllerEventManagerTest > testSuccessfulEvent() PASSED

ControllerEventManagerTest > testMetricsCleanedOnClose() STARTED

ControllerEventManagerTest > testMetricsCleanedOnClose() PASSED

ControllerChannelManagerTest > 
testStopReplicaRequestWithAlreadyDefinedDeletedPartition() STARTED

ControllerChannelManagerTest > 
testStopReplicaRequestWithAlreadyDefinedDeletedPartition() PASSED

ControllerChannelManagerTest > testUpdateMetadataInterBrokerProtocolVersion() 
STARTED

ControllerChannelManagerTest > testUpdateMetadataInterBrokerProtocolVersion() 
PASSED

ControllerChannelManagerTest > testLeaderAndIsrRequestIsNew() STARTED

ControllerChannelManagerTest > testLeaderAndIsrRequestIsNew() PASSED

ControllerChannelManagerTest > 
testStopReplicaRequestsWhileTopicQueuedForDeletion() STARTED

ControllerChannelManagerTest > 
testStopReplicaRequestsWhileTopicQueuedForDeletion() PASSED

ControllerChannelManagerTest > 
testLeaderAndIsrRequestSentToLiveOrShuttingDownBrokers() STARTED

ControllerChannelManagerTest > 
testLeaderAndIsrRequestSentToLiveOrShuttingDownBrokers() PASSED

ControllerChannelManagerTest > testStopReplicaInterBrokerProtocolVersion() 
STARTED

ControllerChannelManagerTest > testStopReplicaInterBrokerProtocolVersion() 
PASSED

ControllerChannelManagerTest > 
testStopReplicaSentOnlyToLiveAndShuttingDownBrokers() STARTED

ControllerChannelManagerTest > 
testStopReplicaSentOnlyToLiveAndShuttingDownBrokers() PASSED

ControllerChannelManagerTest > testStopReplicaGroupsByBroker() STARTED

ControllerChannelManagerTest > testStopReplicaGroupsByBroker() PASSED

ControllerChannelManagerTest > 
testUpdateMetadataDoesNotIncludePartitionsWithoutLeaderAndIsr() STARTED

ControllerChannelManagerTest > 
testUpdateMetadataDoesNotIncludePartitionsWithoutLeaderAndIsr() PASSED

ControllerChannelManagerTest > testMixedDeleteAndNotDeleteStopReplicaRequests() 
STARTED

ControllerChannelManagerTest > testMixedDeleteAndNotDeleteStopReplicaRequests() 
PASSED

ControllerChannelManagerTest > testLeaderAndIsrInterBrokerProtocolVersion() 
STARTED

ControllerChannelManagerTest > testLeaderAndIsrInterBrokerProtocolVersion() 
PASSED

ControllerChannelManagerTest > testUpdateMetadataRequestSent() STARTED

ControllerChannelManagerTest > testUpdateMetadataRequestSent() PASSED

ControllerChannelManagerTest > testUpdateMetadataRequestDuringTopicDeletion() 
STARTED

ControllerChannelManagerTest > testUpdateMetadataRequestDuringTopicDeletion() 
PASSED

ControllerChannelManagerTest > 
testUpdateMetadataIncludesLiveOrShuttingDownBrokers() STARTED

ControllerChannelManagerTest > 
testUpdateMetadataIncludesLiveOrShuttingDownBrokers() PASSED

ControllerChannelManagerTest > testStopReplicaRequestSent() STARTED

ControllerChannelManagerTest > testStopReplicaRequestSent() PASSED

ControllerChannelManagerTest > 
testStopReplicaRequestsWhileTopicDeletionStarted() STARTED

ControllerChannelManagerTest > 
testStopReplicaRequestsWhileTopicDeletionStarted() PASSED

ControllerChannelManagerTest > testLeaderAndIsrRequestSent() STARTED

ControllerChannelManagerTest > testLeaderAndIsrRequestSent() PASSED

ControllerChannelManagerTest > 
testStopReplicaRequestWithoutDeletePartitionWhileTopicDeletionStarted() STARTED

ControllerChannelManagerTest > 
testStopReplicaRequestWithoutDeletePartitionWhileTopicDeletionStarted() PASSED

FeatureZNodeTest > testDecodeFailOnInvalidFeatures() STARTED

FeatureZNodeTest > testDecodeFailOnInvalidFeatures() PASSED

FeatureZNodeTest > testEncodeDecode() STARTED

FeatureZNodeTest > testEncodeDecode() PASSED

FeatureZNodeTest > testDecodeSuccess() STARTED

FeatureZNodeTest > testDecodeSuccess() PASSED

FeatureZNodeTest > testDecodeFailOnInvalidVersionAndStatus() STARTED

FeatureZNodeTest > testDecodeFailOnInvalidVersionAndStatus() PASSED

ExtendedAclStoreTest > shouldHaveCorrectPaths() STARTED

ExtendedAclStoreTest > shouldHaveCorrectPaths() PASSED

ExtendedAclStoreTest > shouldRoundTripChangeNode() STARTED

ExtendedAclStoreTest > shouldRoundTripChangeNode() PASSED

ExtendedAclStoreTest > shouldThrowFromEncodeOnLiteral() STARTED

ExtendedAclStoreTest > shouldThrowFromEncodeOnLiteral() PASSED

ExtendedAclStoreTest > shouldThrowIfConstructedWithLiteral() STARTED

ExtendedAclStoreTest > shouldThrowIfConstructedWithLiteral() PASSED

ExtendedAclStoreTest > shouldWriteChangesToTheWritePath() STARTED

ExtendedAclStoreTest > shouldWriteChangesToTheWritePath() PASSED

ExtendedAclStoreTest > shouldHaveCorrectPatternType() STARTED

ExtendedAclStoreTest > shouldHaveCorrectPatternType() PASSED

DefaultMessageFormatterTest > [1] name=print nothing, 
record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, 
offset = 9876, CreateTime = 1234, serial

Re: [VOTE] KIP-695: Improve Streams Time Synchronization

[John Roesler]

Hello again, all.

I have submitted the PR:
https://github.com/apache/kafka/pull/10096

Ismael chimed in on the PR review to indicate that the
config approach may not be desirable.

How strongly do we feel that the behavior change is
unacceptable? It seems like most of the people involved felt
the behavior change is ok (although the docs were wrong).

The arguments against the behavior change were plausible,
but hypothetical.

Can everyone take a look at the PR and weigh in on whether
the complexity of an extra config option is really worth it
in this case?

I have to confess I'm currently leaning more toward dropping
the config and going back to the behavior change, while
correcting the docs and the system test.

While we are wavering on this point, the system tests
continue to fail, and the 2.8.0 release is blocked. We
should aim to make a call today.

Thanks all,
-John

On Fri, 2021-02-05 at 15:31 -0800, Guozhang Wang wrote:
> Thanks everyone for chiming in here! I'd also prefer the config approach if
> compared with API changes.
> 
> On Fri, Feb 5, 2021 at 3:18 PM Bill Bejeck  wrote:
> 
> > I meant to chime in earlier.
> > 
> > I also like the `PollOptions` idea, but I have to agree that the config
> > option would be the least disruptive approach.
> > 
> > Thanks,
> > Bill
> > 
> > On Fri, Feb 5, 2021 at 6:12 PM John Roesler  wrote:
> > 
> > > Thanks, all!
> > > 
> > > It seems that the config I proposed is a solution that
> > > everyone can be happy with, so I will go ahead with a PR to
> > > fix that.
> > > 
> > > I'll update the KIP after a round of PR reviews, in case
> > > there are new concerns that arise.
> > > 
> > > Thanks,
> > > -John
> > > 
> > > On Fri, 2021-02-05 at 15:07 -0800, Matthias J. Sax wrote:
> > > > Thanks for providing more details.
> > > > 
> > > > Adding a config might be the way a least resistance... I am fine with
> > > that.
> > > > 
> > > > -Matthias
> > > > 
> > > > On 2/4/21 9:42 AM, Chia-Ping Tsai wrote:
> > > > > > vvv
> > > > > > long_poll.mode: return_on_records|return_on_response
> > > > > 
> > > > > This idea LGTM. It not only makes minimum changes to current behavior
> > > but also works for KIP-695.
> > > > > 
> > > > > On 2021/02/04 16:07:11, John Roesler  wrote:
> > > > > > Hi Matthias, Chia-Ping, and Tom,
> > > > > > 
> > > > > > Thanks for the thoughtful replies!
> > > > > > 
> > > > > > Re: poll(~forever~) to block indefinitely on records:
> > > > > > Thanks for your dilligence, Chia-Ping. While I wouldn't
> > > > > > personally recommend for anyone to write code that blocks
> > > > > > forever on I/O, I do agree this is something that "real
> > > > > > people" may want to do.
> > > > > > 
> > > > > > Just a note for the record, this approach should only be
> > > > > > used in conjunction with a manual assignment. If people are
> > > > > > using a group subscription, they're setting themselves up to
> > > > > > get kicked out of the group when there is low volume of
> > > > > > updates on the topic. And then, when they get kicked out,
> > > > > > they will never know it because they're just going to be
> > > > > > blocked in `poll()` the whole time.
> > > > > > 
> > > > > > However, if you don't participate in a group and just:
> > > > > > 1 assign(partitions)
> > > > > > 2 poll(forever),
> > > > > > you should indeed expect to return from poll only when you
> > > > > > have records.
> > > > > > 
> > > > > > This possibility is the turning point for me. I'd like to
> > > > > > alter my proposal to an opt-in config, detailed below.
> > > > > > 
> > > > > > Re: Javadoc:
> > > > > > Thanks for pointing that out. It does seem like, if we do
> > > > > > decide to change behavior, we should adjust the Javadoc to
> > > > > > say so. That was an oversight on my part, and I daresay that
> > > > > > if I had done that initially, it would have saved Rajini
> > > > > > from having to dig into the code to pinpoint the cause of
> > > > > > those test failures.
> > > > > > 
> > > > > > Re: PollOptions:
> > > > > > I actually like this option quite a bit. It seems like this
> > > > > > would be warranted if we expect someone to want to use the
> > > > > > same Consumer instance in both "return on metadata or
> > > > > > records" and "return on only records" mode. Otherwise, we
> > > > > > might as well introduce a new config.
> > > > > > 
> > > > > > It also seems like the behavior I proposed in this KIP is
> > > > > > somewhat "advanced", so I could certainly see leaving it off
> > > > > > by default and offering an opt-in config.
> > > > > > 
> > > > > > How does everyone feel about this opt-in config:
> > > > > > 
> > > > > > vvv
> > > > > > long_poll.mode: return_on_records|return_on_response
> > > > > > 
> > > > > > doc:
> > > > > > * return_on_records: (default) a call to
> > > > > > Consumer#poll(timeout) will block up to the timeout and
> > > > > > return early if records are received.
> > > > > > * return_on_response: a call to Cons

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

[Apache Jenkins Server]

See 


Changes:

[github] MINOR: KafkaBroker.brokerState should be volatile instead of 
AtomicReference (#10080)


--
[...truncated 7.23 MB...]

LogCleanerManagerTest > testMaybeTruncateCheckpointShouldTruncateData() STARTED

LogCleanerManagerTest > testMaybeTruncateCheckpointShouldTruncateData() PASSED

LogCleanerManagerTest > testGrabFilthiestCompactedLogThrowsException() STARTED

LogCleanerManagerTest > testGrabFilthiestCompactedLogThrowsException() PASSED

LogCleanerManagerTest > 
testLogsWithSegmentsToDeleteShouldNotConsiderUncleanablePartitions() STARTED

LogCleanerManagerTest > 
testLogsWithSegmentsToDeleteShouldNotConsiderUncleanablePartitions() PASSED

LogCleanerManagerTest > testLogStartOffsetLargerThanActiveSegmentBaseOffset() 
STARTED

LogCleanerManagerTest > testLogStartOffsetLargerThanActiveSegmentBaseOffset() 
PASSED

LogCleanerManagerTest > testDirtyOffsetResetIfSmallerThanStartOffset() STARTED

LogCleanerManagerTest > testDirtyOffsetResetIfSmallerThanStartOffset() PASSED

LogCleanerManagerTest > 
testLogsWithSegmentsToDeleteShouldNotConsiderCleanupPolicyDeleteLogs() STARTED

LogCleanerManagerTest > 
testLogsWithSegmentsToDeleteShouldNotConsiderCleanupPolicyDeleteLogs() PASSED

LogCleanerManagerTest > testHandleLogDirFailureShouldRemoveDirAndData() STARTED

LogCleanerManagerTest > testHandleLogDirFailureShouldRemoveDirAndData() PASSED

LogCleanerManagerTest > testConcurrentLogCleanupAndTopicDeletion() STARTED

LogCleanerManagerTest > testConcurrentLogCleanupAndTopicDeletion() PASSED

LogCleanerManagerTest > testUpdateCheckpointsShouldAddOffsetToPartition() 
STARTED

LogCleanerManagerTest > testUpdateCheckpointsShouldAddOffsetToPartition() PASSED

LogCleanerManagerTest > testCleanableOffsetsForShortTime() STARTED

LogCleanerManagerTest > testCleanableOffsetsForShortTime() PASSED

LogCleanerManagerTest > testCleanableOffsetsNeedsCheckpointReset() STARTED

LogCleanerManagerTest > testCleanableOffsetsNeedsCheckpointReset() PASSED

LogCleanerManagerTest > 
testGrabFilthiestCompactedLogReturnsLogWithDirtiestRatio() STARTED

LogCleanerManagerTest > 
testGrabFilthiestCompactedLogReturnsLogWithDirtiestRatio() PASSED

LogCleanerManagerTest > testCheckpointUpdatedForInvalidOffsetNoCleaning() 
STARTED

LogCleanerManagerTest > testCheckpointUpdatedForInvalidOffsetNoCleaning() PASSED

LogCleanerManagerTest > testDirtyOffsetResetIfLargerThanEndOffset() STARTED

LogCleanerManagerTest > testDirtyOffsetResetIfLargerThanEndOffset() PASSED

LogCleanerManagerTest > 
testGrabFilthiestCompactedLogIgnoresBothInProgressPartitionsAndUncleanablePartitions()
 STARTED

LogCleanerManagerTest > 
testGrabFilthiestCompactedLogIgnoresBothInProgressPartitionsAndUncleanablePartitions()
 PASSED

LogCleanerManagerTest > testDoneCleaning() STARTED

LogCleanerManagerTest > testDoneCleaning() PASSED

LogCleanerManagerTest > testDoneDeleting() STARTED

LogCleanerManagerTest > testDoneDeleting() PASSED

TransactionIndexTest > testTruncate() STARTED

TransactionIndexTest > testTruncate() PASSED

TransactionIndexTest > testAbortedTxnSerde() STARTED

TransactionIndexTest > testAbortedTxnSerde() PASSED

TransactionIndexTest > testRenameIndex() STARTED

TransactionIndexTest > testRenameIndex() PASSED

TransactionIndexTest > testPositionSetCorrectlyWhenOpened() STARTED

TransactionIndexTest > testPositionSetCorrectlyWhenOpened() PASSED

TransactionIndexTest > testLastOffsetCannotDecrease() STARTED

TransactionIndexTest > testLastOffsetCannotDecrease() PASSED

TransactionIndexTest > testLastOffsetMustIncrease() STARTED

TransactionIndexTest > testLastOffsetMustIncrease() PASSED

TransactionIndexTest > testSanityCheck() STARTED

TransactionIndexTest > testSanityCheck() PASSED

TransactionIndexTest > testCollectAbortedTransactions() STARTED

TransactionIndexTest > testCollectAbortedTransactions() PASSED

LogConfigTest > testGetConfigValue() STARTED

LogConfigTest > testGetConfigValue() PASSED

LogConfigTest > testToRst() STARTED

LogConfigTest > testToRst() PASSED

LogConfigTest > ensureNoStaticInitializationOrderDependency() STARTED

LogConfigTest > ensureNoStaticInitializationOrderDependency() PASSED

LogConfigTest > testToEnrichedRst() STARTED

LogConfigTest > testToEnrichedRst() PASSED

LogConfigTest > shouldValidateThrottledReplicasConfig() STARTED

LogConfigTest > shouldValidateThrottledReplicasConfig() PASSED

LogConfigTest > testFromPropsEmpty() STARTED

LogConfigTest > testFromPropsEmpty() PASSED

LogConfigTest > testInvalidCompactionLagConfig() STARTED

LogConfigTest > testInvalidCompactionLagConfig() PASSED

LogConfigTest > testKafkaConfigToProps() STARTED

LogConfigTest > testKafkaConfigToProps() PASSED

LogConfigTest > testFromPropsInvalid() STARTED

LogConfigTest > testFromPropsInvalid() PASSED

LogConfigTest > testToHtmlTable() STARTED

LogConfigTest > testToHtmlTable() PASSED

LogConfigTest >

Re: [DISCUSS] Apache Kafka 2.6.2 release

[Sophie Blee-Goldman]

Ok, thanks for the update!

On Wed, Feb 10, 2021 at 1:06 AM Luke Chen  wrote:

> Hi Ismael & Sophie,
> Sorry, after some investigation, I think this might not be a defect. To
> work with the project with a specific scala version, user might need to use
> the same version as the project used. This issue also happened on other
> projects using scala, ex: Spark. ref: https://stackoverflow.com/a/61677956
> .
>
> So, you can continue to cut the rc.
>
> Thank you very much.
> Luke
>
> On Wed, Feb 10, 2021 at 11:19 AM Luke Chen  wrote:
>
> > I just saw the defect KAFKA-12312
> > , so I brought it to
> > your attention.
> > Do you think it's not a compatibility issue? If not, I think we don't
> need
> > to cherry-pick the fix.
> >
> > Thanks.
> > Luke
> >
> > On Wed, Feb 10, 2021 at 11:16 AM Ismael Juma  wrote:
> >
> >> It's a perf improvement, there was no regression. I think Luke needs to
> be
> >> clearer how this impacts users. Luke, are you referring to cases where
> >> someone runs the broker in an embedded scenario (eg tests)?
> >>
> >> Ismael
> >>
> >> On Tue, Feb 9, 2021, 6:50 PM Sophie Blee-Goldman 
> >> wrote:
> >>
> >> > What do you think Ismael? I agreed initially because I saw the commit
> >> > message says it fixes a performance regression. But admittedly I don't
> >> have
> >> > much context on this particular issue
> >> >
> >> > If it's low risk then I don't have a strong argument against including
> >> it.
> >> > However
> >> > I aim to cut the rc tomorrow or Thursday, and if it hasn't been
> >> > cherrypicked by then
> >> > I won't block the release on it.
> >> >
> >> > On Tue, Feb 9, 2021 at 4:53 PM Luke Chen  wrote:
> >> >
> >> > > Hi Ismael,
> >> > > Yes, I agree it's like an improvement, not a bug. I don't insist on
> >> > putting
> >> > > it into 2.6, just want to bring it to your attention.
> >> > > In my opinion, this issue will block users who adopt the scala
> 2.13.4
> >> or
> >> > > later to use Kafka 2.6.
> >> > > So if we still have time, we can consider to cherry-pick the fix
> into
> >> 2.6
> >> > > and 2.7.
> >> > >
> >> > > What do you think?
> >> > >
> >> > > Thank you.
> >> > > Luke
> >> > >
> >> > > On Wed, Feb 10, 2021 at 3:24 AM Ismael Juma 
> >> wrote:
> >> > >
> >> > > > Can you elaborate why this needs to be in 2.6? Seems like an
> >> > improvement
> >> > > > versus a critical bug fix.
> >> > > >
> >> > > > Ismael
> >> > > >
> >> > > > On Mon, Feb 8, 2021 at 6:39 PM Luke Chen 
> wrote:
> >> > > >
> >> > > > > Hi Sophie,
> >> > > > > I found there is 1 issue that should be cherry-picked into 2.6
> and
> >> > 2.7
> >> > > > > branches: KAFKA-12312 <
> >> > > https://issues.apache.org/jira/browse/KAFKA-12312
> >> > > > >.
> >> > > > > Simply put, *Scala* *2.13.4* is released at the end of 2020, and
> >> we
> >> > > > > upgraded to it and fixed some compatible issues on this PR
> >> > > > > , more specifically,
> >> it's
> >> > > > here
> >> > > > > <
> >> > > > >
> >> > > >
> >> > >
> >> >
> >>
> https://github.com/apache/kafka/pull/9643/files#diff-fda3fb44e69a19600913bd951431fb0035996c76325b1c1d84d6f34bec281205R292
> >> > > > > >
> >> > > > > .
> >> > > > > We only merged this fix on *trunk*(which will be on 2.8), but we
> >> > didn't
> >> > > > > tell users (or we didn't know there'll be compatible issues) not
> >> to
> >> > > adopt
> >> > > > > the latest *Scala* *2.13.4*.
> >> > > > >
> >> > > > > Therefore, I think we should cherry-pick this fix into 2.6 and
> 2.7
> >> > > > > branches. What do you think?
> >> > > > >
> >> > > > > Thank you.
> >> > > > > Luke
> >> > > > >
> >> > > > >
> >> > > > >
> >> > > > >
> >> > > > >
> >> > > > > On Tue, Feb 9, 2021 at 3:10 AM Sophie Blee-Goldman <
> >> > > sop...@confluent.io>
> >> > > > > wrote:
> >> > > > >
> >> > > > > > Hey all,
> >> > > > > >
> >> > > > > > Since all outstanding bugfixes seem to have made their way
> over
> >> to
> >> > > the
> >> > > > > 2.6
> >> > > > > > branch by now, I plan to move ahead with cutting an RC. As
> >> always,
> >> > > > please
> >> > > > > > let me know if you uncover and critical or blocker bugs that
> >> affect
> >> > > 2.6
> >> > > > > >
> >> > > > > > Thanks!
> >> > > > > > Sophie
> >> > > > > >
> >> > > > > > On Thu, Jan 28, 2021 at 9:25 AM John Roesler <
> >> vvcep...@apache.org>
> >> > > > > wrote:
> >> > > > > >
> >> > > > > > > Thanks so much for stepping up, Sophie!
> >> > > > > > >
> >> > > > > > > I'm +1
> >> > > > > > >
> >> > > > > > > -John
> >> > > > > > >
> >> > > > > > > On Wed, 2021-01-27 at 17:59 -0500, Bill Bejeck wrote:
> >> > > > > > > > Thanks for taking this on Sophie. +1
> >> > > > > > > >
> >> > > > > > > > Bill
> >> > > > > > > >
> >> > > > > > > > On Wed, Jan 27, 2021 at 5:59 PM Ismael Juma <
> >> ism...@juma.me.uk
> >> > >
> >> > > > > wrote:
> >> > > > > > > >
> >> > > > > > > > > Thanks Sophie! +1
> >> > > > > > > > >
> >> > > > > > > > > Ismael
> >> > > > > > > > >

[jira] [Resolved] (KAFKA-12322) Why https://downloads.apache.org/kafka/ it doesnot download older version only 2.7.0 and 2.6.1 ,is there any changes done ?

[Matthias J. Sax (Jira)]

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

Matthias J. Sax resolved KAFKA-12322.
-
Resolution: Not A Problem

> Why https://downloads.apache.org/kafka/  it doesnot download older version 
> only 2.7.0 and 2.6.1 ,is there any changes done ?
> 
>
> Key: KAFKA-12322
> URL: https://issues.apache.org/jira/browse/KAFKA-12322
> Project: Kafka
>  Issue Type: Bug
>Reporter: suman tripathi
>Priority: Major
>




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

Re: [VOTE] KIP-695: Improve Streams Time Synchronization

[Sophie Blee-Goldman]

Hey John, I know I'm a bit late to this party but just for the record,
I don't think it's *totally *unreasonable for a user to take up the "poll
on max timeout and assume some records will be returned" approach.
And I also can imagine plenty of manually-assigned consumers
implemented doing exactly that.

It's too bad that we're hitting this during the 2.8 release. If we were
having this discussion in the context of 3.0, then I'd say go for it, since
it's a breaking change that would just require some modification to the
applications' poll loop.

A good analogy here seems to be spurious wakeups -- you generally
assume that a waiting thread has woken up due to a notify event in
another thread, but the docs always make it very clear up front that
this can happen "spuriously" and therefore you need to recheck whatever
condition you were waiting on before assuming the thread should proceed.

Since we *didn't* document this possibility up front in the case of poll(),
it
seems unfair to suddenly change the behavior in a supposedly non-breaking
release. Imagine how many programs would break if spurious wakeups
were suddenly introduced in a release, rather than warned about from
the get-go (not a perfect analogy, far more programs rely on wait/notify
than on poll() returning records, but I think the point still stands.

For the record, I also agree with Ismael that a config doesn't feel ideal.
There are already enough configs to present a steep learning curve, so
I would avoid adding one more wherever possible. And it does indeed
seem possible to avoid here, since it's really just a boolean flag (rather
than a semi-unbounded space, eg max.poll.interval.ms, or a constant
value, eg group.id, where a config does feel appropriate).

Given all that, I would personally advocate for the pollOptions overload.
The obvious advantages here are:
1) it's more future-proof, in that we can avoid having a similar discussion
if/when we want to consider other semantics changes to poll which some
users may want while others would not
2) it leaves the door open to using poll with either semantics in a single
consumer. I doubt that's going to be very common in terms of the specific
option we're discussing here, but it may be more useful for other options
we may add in the future

Just my 2 cents. But if the pollOptions proposal would really add so much
additional work that it would cause the 2.8 release to be significantly
delayed,
then that's worth taking into account as well.

On Wed, Feb 10, 2021 at 9:35 AM John Roesler  wrote:

> Hello again, all.
>
> I have submitted the PR:
> https://github.com/apache/kafka/pull/10096
>
> Ismael chimed in on the PR review to indicate that the
> config approach may not be desirable.
>
> How strongly do we feel that the behavior change is
> unacceptable? It seems like most of the people involved felt
> the behavior change is ok (although the docs were wrong).
>
> The arguments against the behavior change were plausible,
> but hypothetical.
>
> Can everyone take a look at the PR and weigh in on whether
> the complexity of an extra config option is really worth it
> in this case?
>
> I have to confess I'm currently leaning more toward dropping
> the config and going back to the behavior change, while
> correcting the docs and the system test.
>
> While we are wavering on this point, the system tests
> continue to fail, and the 2.8.0 release is blocked. We
> should aim to make a call today.
>
> Thanks all,
> -John
>
> On Fri, 2021-02-05 at 15:31 -0800, Guozhang Wang wrote:
> > Thanks everyone for chiming in here! I'd also prefer the config approach
> if
> > compared with API changes.
> >
> > On Fri, Feb 5, 2021 at 3:18 PM Bill Bejeck  wrote:
> >
> > > I meant to chime in earlier.
> > >
> > > I also like the `PollOptions` idea, but I have to agree that the config
> > > option would be the least disruptive approach.
> > >
> > > Thanks,
> > > Bill
> > >
> > > On Fri, Feb 5, 2021 at 6:12 PM John Roesler 
> wrote:
> > >
> > > > Thanks, all!
> > > >
> > > > It seems that the config I proposed is a solution that
> > > > everyone can be happy with, so I will go ahead with a PR to
> > > > fix that.
> > > >
> > > > I'll update the KIP after a round of PR reviews, in case
> > > > there are new concerns that arise.
> > > >
> > > > Thanks,
> > > > -John
> > > >
> > > > On Fri, 2021-02-05 at 15:07 -0800, Matthias J. Sax wrote:
> > > > > Thanks for providing more details.
> > > > >
> > > > > Adding a config might be the way a least resistance... I am fine
> with
> > > > that.
> > > > >
> > > > > -Matthias
> > > > >
> > > > > On 2/4/21 9:42 AM, Chia-Ping Tsai wrote:
> > > > > > > vvv
> > > > > > > long_poll.mode: return_on_records|return_on_response
> > > > > >
> > > > > > This idea LGTM. It not only makes minimum changes to current
> behavior
> > > > but also works for KIP-695.
> > > > > >
> > > > > > On 2021/02/04 16:07:11, John Roesler 
> wrote:
> > > > > > > Hi Matthias, Chia-Ping, and Tom,
> > > 

Re: [DISCUSS] KIP-712: Shallow Mirroring

[Vahid Hashemian]

Retitled the thread to conform to the common format.

On Fri, Feb 5, 2021 at 4:00 PM Ning Zhang  wrote:

> Hello Henry,
>
> This is a very interesting proposal.
> https://issues.apache.org/jira/browse/KAFKA-10728 reflects the similar
> concern of re-compressing data in mirror maker.
>
> Probably one thing may need to clarify is: how "shallow" mirroring is only
> applied to mirrormaker use case, if the changes need to be made on generic
> consumer and producer (e.g. by adding `fetch.raw.bytes` and
> `send.raw.bytes` to producer and consumer config)
>
> On 2021/02/05 00:59:57, Henry Cai  wrote:
> > Dear Community members,
> >
> > We are proposing a new feature to improve the performance of Kafka mirror
> > maker:
> >
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-712%3A+Shallow+Mirroring
> >
> > The current Kafka MirrorMaker process (with the underlying Consumer and
> > Producer library) uses significant CPU cycles and memory to
> > decompress/recompress, deserialize/re-serialize messages and copy
> multiple
> > times of messages bytes along the mirroring/replicating stages.
> >
> > The KIP proposes a *shallow mirror* feature which brings back the shallow
> > iterator concept to the mirror process and also proposes to skip the
> > unnecessary message decompression and recompression steps.  We argue in
> > many cases users just want a simple replication pipeline to replicate the
> > message as it is from the source cluster to the destination cluster.  In
> > many cases the messages in the source cluster are already compressed and
> > properly batched, users just need an identical copy of the message bytes
> > through the mirroring without any transformation or repartitioning.
> >
> > We have a prototype implementation in house with MirrorMaker v1 and
> > observed *CPU usage dropped from 50% to 15%* for some mirror pipelines.
> >
> > We name this feature: *shallow mirroring* since it has some resemblance
> to
> > the old Kafka 0.7 namesake feature but the implementations are not quite
> > the same.  ‘*Shallow*’ means 1. we *shallowly* iterate RecordBatches
> inside
> > MemoryRecords structure instead of deep iterating records inside
> > RecordBatch; 2. We *shallowly* copy (share) pointers inside ByteBuffer
> > instead of deep copying and deserializing bytes into objects.
> >
> > Please share discussions/feedback along this email thread.
> >
>


-- 

Thanks!
--Vahid

Re: [DISCUSS] KIP-712: Shallow Mirroring

[Henry Cai]

On the question "whether shallow mirror is only applied on mirror maker
v1", the code change is mostly on consumer and producer code path, the
change to mirrormaker v1 is very trivial.  We chose to modify the
consumer/producer path (instead of creating a new mirror product) so other
use cases can use that feature as well.  The change to mirror maker v2
should be straightforward as well but we don't have that environment in
house.  I think the community can easily port this change to mirror maker
v2.



On Wed, Feb 10, 2021 at 12:58 PM Vahid Hashemian 
wrote:

> Retitled the thread to conform to the common format.
>
> On Fri, Feb 5, 2021 at 4:00 PM Ning Zhang  wrote:
>
> > Hello Henry,
> >
> > This is a very interesting proposal.
> > https://issues.apache.org/jira/browse/KAFKA-10728 reflects the similar
> > concern of re-compressing data in mirror maker.
> >
> > Probably one thing may need to clarify is: how "shallow" mirroring is
> only
> > applied to mirrormaker use case, if the changes need to be made on
> generic
> > consumer and producer (e.g. by adding `fetch.raw.bytes` and
> > `send.raw.bytes` to producer and consumer config)
> >
> > On 2021/02/05 00:59:57, Henry Cai  wrote:
> > > Dear Community members,
> > >
> > > We are proposing a new feature to improve the performance of Kafka
> mirror
> > > maker:
> > >
> >
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-712%3A+Shallow+Mirroring
> > >
> > > The current Kafka MirrorMaker process (with the underlying Consumer and
> > > Producer library) uses significant CPU cycles and memory to
> > > decompress/recompress, deserialize/re-serialize messages and copy
> > multiple
> > > times of messages bytes along the mirroring/replicating stages.
> > >
> > > The KIP proposes a *shallow mirror* feature which brings back the
> shallow
> > > iterator concept to the mirror process and also proposes to skip the
> > > unnecessary message decompression and recompression steps.  We argue in
> > > many cases users just want a simple replication pipeline to replicate
> the
> > > message as it is from the source cluster to the destination cluster.
> In
> > > many cases the messages in the source cluster are already compressed
> and
> > > properly batched, users just need an identical copy of the message
> bytes
> > > through the mirroring without any transformation or repartitioning.
> > >
> > > We have a prototype implementation in house with MirrorMaker v1 and
> > > observed *CPU usage dropped from 50% to 15%* for some mirror pipelines.
> > >
> > > We name this feature: *shallow mirroring* since it has some resemblance
> > to
> > > the old Kafka 0.7 namesake feature but the implementations are not
> quite
> > > the same.  ‘*Shallow*’ means 1. we *shallowly* iterate RecordBatches
> > inside
> > > MemoryRecords structure instead of deep iterating records inside
> > > RecordBatch; 2. We *shallowly* copy (share) pointers inside ByteBuffer
> > > instead of deep copying and deserializing bytes into objects.
> > >
> > > Please share discussions/feedback along this email thread.
> > >
> >
>
>
> --
>
> Thanks!
> --Vahid
>

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

[Apache Jenkins Server]

See 


Changes:

[github] MINOR: Rename DecommissionBrokers to UnregisterBrokers (#10084)


--
[...truncated 3.63 MB...]
AuthorizerIntegrationTest > 
testTransactionalProducerInitTransactionsNoDescribeTransactionalIdAcl() PASSED

AuthorizerIntegrationTest > testAuthorizeByResourceTypeDenyTakesPrecedence() 
STARTED

AuthorizerIntegrationTest > testAuthorizeByResourceTypeDenyTakesPrecedence() 
PASSED

AuthorizerIntegrationTest > testUnauthorizedDeleteRecordsWithDescribe() STARTED

AuthorizerIntegrationTest > testUnauthorizedDeleteRecordsWithDescribe() PASSED

AuthorizerIntegrationTest > testCreateTopicAuthorizationWithClusterCreate() 
STARTED

AuthorizerIntegrationTest > testCreateTopicAuthorizationWithClusterCreate() 
PASSED

AuthorizerIntegrationTest > testOffsetFetchWithTopicAndGroupRead() STARTED

AuthorizerIntegrationTest > testOffsetFetchWithTopicAndGroupRead() PASSED

AuthorizerIntegrationTest > testCommitWithTopicDescribe() STARTED

AuthorizerIntegrationTest > testCommitWithTopicDescribe() PASSED

AuthorizerIntegrationTest > testAuthorizationWithTopicExisting() STARTED

AuthorizerIntegrationTest > testAuthorizationWithTopicExisting() PASSED

AuthorizerIntegrationTest > testUnauthorizedDeleteRecordsWithoutDescribe() 
STARTED

AuthorizerIntegrationTest > testUnauthorizedDeleteRecordsWithoutDescribe() 
PASSED

AuthorizerIntegrationTest > testMetadataWithTopicDescribe() STARTED

AuthorizerIntegrationTest > testMetadataWithTopicDescribe() PASSED

AuthorizerIntegrationTest > testProduceWithTopicDescribe() STARTED

AuthorizerIntegrationTest > testProduceWithTopicDescribe() PASSED

AuthorizerIntegrationTest > testDescribeGroupApiWithNoGroupAcl() STARTED

AuthorizerIntegrationTest > testDescribeGroupApiWithNoGroupAcl() PASSED

AuthorizerIntegrationTest > testPatternSubscriptionMatchingInternalTopic() 
STARTED

AuthorizerIntegrationTest > testPatternSubscriptionMatchingInternalTopic() 
PASSED

AuthorizerIntegrationTest > testSendOffsetsWithNoConsumerGroupDescribeAccess() 
STARTED

AuthorizerIntegrationTest > testSendOffsetsWithNoConsumerGroupDescribeAccess() 
PASSED

AuthorizerIntegrationTest > testOffsetFetchTopicDescribe() STARTED

AuthorizerIntegrationTest > testOffsetFetchTopicDescribe() PASSED

AuthorizerIntegrationTest > testCommitWithTopicAndGroupRead() STARTED

AuthorizerIntegrationTest > testCommitWithTopicAndGroupRead() PASSED

AuthorizerIntegrationTest > 
testIdempotentProducerNoIdempotentWriteAclInInitProducerId() STARTED

AuthorizerIntegrationTest > 
testIdempotentProducerNoIdempotentWriteAclInInitProducerId() PASSED

AuthorizerIntegrationTest > testSimpleConsumeWithExplicitSeekAndNoGroupAccess() 
STARTED

AuthorizerIntegrationTest > testSimpleConsumeWithExplicitSeekAndNoGroupAccess() 
PASSED

SslProducerSendTest > testSendNonCompressedMessageWithCreateTime() STARTED

SslProducerSendTest > testSendNonCompressedMessageWithCreateTime() PASSED

SslProducerSendTest > testClose() STARTED

SslProducerSendTest > testClose() PASSED

SslProducerSendTest > testFlush() STARTED

SslProducerSendTest > testFlush() PASSED

SslProducerSendTest > testSendToPartition() STARTED

SslProducerSendTest > testSendToPartition() PASSED

SslProducerSendTest > testSendOffset() STARTED

SslProducerSendTest > testSendOffset() PASSED

SslProducerSendTest > testSendCompressedMessageWithCreateTime() STARTED

SslProducerSendTest > testSendCompressedMessageWithCreateTime() PASSED

SslProducerSendTest > testCloseWithZeroTimeoutFromCallerThread() STARTED

SslProducerSendTest > testCloseWithZeroTimeoutFromCallerThread() PASSED

SslProducerSendTest > testCloseWithZeroTimeoutFromSenderThread() STARTED

SslProducerSendTest > testCloseWithZeroTimeoutFromSenderThread() PASSED

SslProducerSendTest > testSendBeforeAndAfterPartitionExpansion() STARTED

SslProducerSendTest > testSendBeforeAndAfterPartitionExpansion() PASSED

ProducerCompressionTest > [1] compression=none STARTED

ProducerCompressionTest > [1] compression=none PASSED

ProducerCompressionTest > [2] compression=gzip STARTED

ProducerCompressionTest > [2] compression=gzip PASSED

ProducerCompressionTest > [3] compression=snappy STARTED

ProducerCompressionTest > [3] compression=snappy PASSED

ProducerCompressionTest > [4] compression=lz4 STARTED

ProducerCompressionTest > [4] compression=lz4 PASSED

ProducerCompressionTest > [5] compression=zstd STARTED

ProducerCompressionTest > [5] compression=zstd PASSED

MetricsTest > testMetrics() STARTED

MetricsTest > testMetrics() PASSED

ProducerFailureHandlingTest > testCannotSendToInternalTopic() STARTED

ProducerFailureHandlingTest > testCannotSendToInternalTopic() PASSED

ProducerFailureHandlingTest > testTooLargeRecordWithAckOne() STARTED

ProducerFailureHandlingTest > testTooLargeRecordWithAckOne() PASSED

ProducerFailureHandlingTest > testWrongBrokerList() STARTED

ProducerFailureHandlingTest > tes

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

[Apache Jenkins Server]

See 


Changes:

[github] MINOR: Rename DecommissionBrokers to UnregisterBrokers (#10084)


--
[...truncated 3.49 MB...]
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

PlaintextEndToEndAuthorizationTest > testProduceConsumeWithWildcardAcls() PASSED

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

KafkaZkClientTest > testPropagateIsrChanges() STARTED

KafkaZkClientTest > testPropagateIsrChanges() PASSED

KafkaZkClientTest > testControllerEpochMethods() STARTED

KafkaZkClientTest > testControllerEpochMethods() PASSED

KafkaZkClientTest > testDeleteRecursive() STARTED

KafkaZkClientTest > testDeleteRecursive() PASSED

KafkaZkClientTest > testGetTopicPartitionStates() STARTED

KafkaZkClientTest > testGetTopicPartitionStates() PASSED

KafkaZkClientTest > testCreateConfigChangeNotification() STARTED

KafkaZkClientTest > testCreateConfigChangeNotification() PASSED

KafkaZkClientTest > testDelegationTokenMethods() STARTED

KafkaZkClientTest > testDelegationTokenMethods() PASSED

LiteralAclStoreTest > shouldHaveCorrectPaths() STARTED

LiteralAclStoreTest > shouldHaveCorrectPaths() PASSED

LiteralAclStoreTest > shouldRoundTripChangeNode() STARTED

LiteralAclStoreTest > shouldRoundTripChangeNode() PASSED

LiteralAclStoreTest > shouldThrowFromEncodeOnNoneLiteral() STARTED

LiteralAclStoreTest > shouldThrowFromEncodeOnNoneLiteral() PASSED

LiteralAclStoreTest > shouldWriteChangesToTheWritePath() STARTED

LiteralAclStoreTest > shouldWriteChangesToTheWritePath() PASSED

LiteralAclStoreTest > shouldHaveCorrectPatternType() STARTED

LiteralAclStoreTest > shouldHaveCorrectPatternType() PASSED

LiteralAclStoreTest > shouldDecodeResourceUsingTwoPartLogic() STARTED

LiteralAclStoreTest > shouldDecodeResourceUsingTwoPartLogic() PASSED

ReassignPartitionsZNodeTest > testDecodeInvalidJson() STARTED

ReassignPartitionsZNodeTest > testDecodeInvalidJson() PASSED

ReassignPartitionsZNodeTest > testEncode() STARTED

ReassignPartitionsZNodeTest > testEncode() PASSED

ReassignPartitionsZNodeTest > testDecodeValidJson() STARTED

ReassignPartitionsZNodeTest > testDecodeValidJson() PASSED

Contr

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

[Apache Jenkins Server]

See 


Changes:

[github] MINOR: Rename DecommissionBrokers to UnregisterBrokers (#10084)


--
[...truncated 3.49 MB...]
LogValidatorTest > testNonCompressedV1() STARTED

LogValidatorTest > testNonCompressedV1() PASSED

LogValidatorTest > testNonCompressedV2() STARTED

LogValidatorTest > testNonCompressedV2() PASSED

LogValidatorTest > testOffsetAssignmentAfterUpConversionV1ToV2NonCompressed() 
STARTED

LogValidatorTest > testOffsetAssignmentAfterUpConversionV1ToV2NonCompressed() 
PASSED

LogValidatorTest > testInvalidCreateTimeCompressedV1() STARTED

LogValidatorTest > testInvalidCreateTimeCompressedV1() PASSED

LogValidatorTest > testInvalidCreateTimeCompressedV2() STARTED

LogValidatorTest > testInvalidCreateTimeCompressedV2() PASSED

LogValidatorTest > testNonIncreasingOffsetRecordBatchHasMetricsLogged() STARTED

LogValidatorTest > testNonIncreasingOffsetRecordBatchHasMetricsLogged() PASSED

LogValidatorTest > testRecompressionV1() STARTED

LogValidatorTest > testRecompressionV1() PASSED

LogValidatorTest > testRecompressionV2() STARTED

LogValidatorTest > testRecompressionV2() PASSED

ProducerStateManagerTest > testSkipEmptyTransactions() STARTED

ProducerStateManagerTest > testSkipEmptyTransactions() PASSED

ProducerStateManagerTest > testControlRecordBumpsProducerEpoch() STARTED

ProducerStateManagerTest > testControlRecordBumpsProducerEpoch() PASSED

ProducerStateManagerTest > testProducerSequenceWithWrapAroundBatchRecord() 
STARTED

ProducerStateManagerTest > testProducerSequenceWithWrapAroundBatchRecord() 
PASSED

ProducerStateManagerTest > testCoordinatorFencing() STARTED

ProducerStateManagerTest > testCoordinatorFencing() PASSED

ProducerStateManagerTest > testLoadFromTruncatedSnapshotFile() STARTED

ProducerStateManagerTest > testLoadFromTruncatedSnapshotFile() PASSED

ProducerStateManagerTest > testTruncateFullyAndStartAt() STARTED

ProducerStateManagerTest > testTruncateFullyAndStartAt() PASSED

ProducerStateManagerTest > testRemoveExpiredPidsOnReload() STARTED

ProducerStateManagerTest > testRemoveExpiredPidsOnReload() PASSED

ProducerStateManagerTest > testRecoverFromSnapshotFinishedTransaction() STARTED

ProducerStateManagerTest > testRecoverFromSnapshotFinishedTransaction() PASSED

ProducerStateManagerTest > testOutOfSequenceAfterControlRecordEpochBump() 
STARTED

ProducerStateManagerTest > testOutOfSequenceAfterControlRecordEpochBump() PASSED

ProducerStateManagerTest > testFirstUnstableOffsetAfterTruncation() STARTED

ProducerStateManagerTest > testFirstUnstableOffsetAfterTruncation() PASSED

ProducerStateManagerTest > testTakeSnapshot() STARTED

ProducerStateManagerTest > testTakeSnapshot() PASSED

ProducerStateManagerTest > testRecoverFromSnapshotUnfinishedTransaction() 
STARTED

ProducerStateManagerTest > testRecoverFromSnapshotUnfinishedTransaction() PASSED

ProducerStateManagerTest > testDeleteSnapshotsBefore() STARTED

ProducerStateManagerTest > testDeleteSnapshotsBefore() PASSED

ProducerStateManagerTest > testAppendEmptyControlBatch() STARTED

ProducerStateManagerTest > testAppendEmptyControlBatch() PASSED

ProducerStateManagerTest > testNoValidationOnFirstEntryWhenLoadingLog() STARTED

ProducerStateManagerTest > testNoValidationOnFirstEntryWhenLoadingLog() PASSED

ProducerStateManagerTest > testRemoveStraySnapshotsKeepCleanShutdownSnapshot() 
STARTED

ProducerStateManagerTest > testRemoveStraySnapshotsKeepCleanShutdownSnapshot() 
PASSED

ProducerStateManagerTest > testRemoveAllStraySnapshots() STARTED

ProducerStateManagerTest > testRemoveAllStraySnapshots() PASSED

ProducerStateManagerTest > testLoadFromEmptySnapshotFile() STARTED

ProducerStateManagerTest > testLoadFromEmptySnapshotFile() PASSED

ProducerStateManagerTest > testProducersWithOngoingTransactionsDontExpire() 
STARTED

ProducerStateManagerTest > testProducersWithOngoingTransactionsDontExpire() 
PASSED

ProducerStateManagerTest > testBasicIdMapping() STARTED

ProducerStateManagerTest > testBasicIdMapping() PASSED

ProducerStateManagerTest > updateProducerTransactionState() STARTED

ProducerStateManagerTest > updateProducerTransactionState() PASSED

ProducerStateManagerTest > testPrepareUpdateDoesNotMutate() STARTED

ProducerStateManagerTest > testPrepareUpdateDoesNotMutate() PASSED

ProducerStateManagerTest > testSequenceNotValidatedForGroupMetadataTopic() 
STARTED

ProducerStateManagerTest > testSequenceNotValidatedForGroupMetadataTopic() 
PASSED

ProducerStateManagerTest > testLastStableOffsetCompletedTxn() STARTED

ProducerStateManagerTest > testLastStableOffsetCompletedTxn() PASSED

ProducerStateManagerTest > testFirstUnstableOffset() STARTED

ProducerStateManagerTest > testFirstUnstableOffset() PASSED

ProducerStateManagerTest > testTxnFirstOffsetMetadataCached() STARTED

ProducerStateManagerTest > testTxnFirstOffsetMetadataCached() PASSED

ProducerStateManagerTest > testCoor

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

[Apache Jenkins Server]

See 


Changes:

[Colin McCabe] MINOR: Rename DecommissionBrokers to UnregisterBrokers (#10084)

[Colin McCabe] JUnit extensions for integration tests (#9986)


--
[...truncated 3.58 MB...]
ControllerEventManagerTest > testSuccessfulEvent() STARTED

ControllerEventManagerTest > testSuccessfulEvent() PASSED

ControllerEventManagerTest > testMetricsCleanedOnClose() STARTED

ControllerEventManagerTest > testMetricsCleanedOnClose() PASSED

ControllerChannelManagerTest > 
testStopReplicaRequestWithAlreadyDefinedDeletedPartition() STARTED

ControllerChannelManagerTest > 
testStopReplicaRequestWithAlreadyDefinedDeletedPartition() PASSED

ControllerChannelManagerTest > testUpdateMetadataInterBrokerProtocolVersion() 
STARTED

ControllerChannelManagerTest > testUpdateMetadataInterBrokerProtocolVersion() 
PASSED

ControllerChannelManagerTest > testLeaderAndIsrRequestIsNew() STARTED

ControllerChannelManagerTest > testLeaderAndIsrRequestIsNew() PASSED

ControllerChannelManagerTest > 
testStopReplicaRequestsWhileTopicQueuedForDeletion() STARTED

ControllerChannelManagerTest > 
testStopReplicaRequestsWhileTopicQueuedForDeletion() PASSED

ControllerChannelManagerTest > 
testLeaderAndIsrRequestSentToLiveOrShuttingDownBrokers() STARTED

ControllerChannelManagerTest > 
testLeaderAndIsrRequestSentToLiveOrShuttingDownBrokers() PASSED

ControllerChannelManagerTest > testStopReplicaInterBrokerProtocolVersion() 
STARTED

ControllerChannelManagerTest > testStopReplicaInterBrokerProtocolVersion() 
PASSED

ControllerChannelManagerTest > 
testStopReplicaSentOnlyToLiveAndShuttingDownBrokers() STARTED

ControllerChannelManagerTest > 
testStopReplicaSentOnlyToLiveAndShuttingDownBrokers() PASSED

ControllerChannelManagerTest > testStopReplicaGroupsByBroker() STARTED

ControllerChannelManagerTest > testStopReplicaGroupsByBroker() PASSED

ControllerChannelManagerTest > 
testUpdateMetadataDoesNotIncludePartitionsWithoutLeaderAndIsr() STARTED

ControllerChannelManagerTest > 
testUpdateMetadataDoesNotIncludePartitionsWithoutLeaderAndIsr() PASSED

ControllerChannelManagerTest > testMixedDeleteAndNotDeleteStopReplicaRequests() 
STARTED

ControllerChannelManagerTest > testMixedDeleteAndNotDeleteStopReplicaRequests() 
PASSED

ControllerChannelManagerTest > testLeaderAndIsrInterBrokerProtocolVersion() 
STARTED

ControllerChannelManagerTest > testLeaderAndIsrInterBrokerProtocolVersion() 
PASSED

ControllerChannelManagerTest > testUpdateMetadataRequestSent() STARTED

ControllerChannelManagerTest > testUpdateMetadataRequestSent() PASSED

ControllerChannelManagerTest > testUpdateMetadataRequestDuringTopicDeletion() 
STARTED

ControllerChannelManagerTest > testUpdateMetadataRequestDuringTopicDeletion() 
PASSED

ControllerChannelManagerTest > 
testUpdateMetadataIncludesLiveOrShuttingDownBrokers() STARTED

ControllerChannelManagerTest > 
testUpdateMetadataIncludesLiveOrShuttingDownBrokers() PASSED

ControllerChannelManagerTest > testStopReplicaRequestSent() STARTED

ControllerChannelManagerTest > testStopReplicaRequestSent() PASSED

ControllerChannelManagerTest > 
testStopReplicaRequestsWhileTopicDeletionStarted() STARTED

ControllerChannelManagerTest > 
testStopReplicaRequestsWhileTopicDeletionStarted() PASSED

ControllerChannelManagerTest > testLeaderAndIsrRequestSent() STARTED

ControllerChannelManagerTest > testLeaderAndIsrRequestSent() PASSED

ControllerChannelManagerTest > 
testStopReplicaRequestWithoutDeletePartitionWhileTopicDeletionStarted() STARTED

ControllerChannelManagerTest > 
testStopReplicaRequestWithoutDeletePartitionWhileTopicDeletionStarted() PASSED

FeatureZNodeTest > testDecodeFailOnInvalidFeatures() STARTED

FeatureZNodeTest > testDecodeFailOnInvalidFeatures() PASSED

FeatureZNodeTest > testEncodeDecode() STARTED

FeatureZNodeTest > testEncodeDecode() PASSED

FeatureZNodeTest > testDecodeSuccess() STARTED

FeatureZNodeTest > testDecodeSuccess() PASSED

FeatureZNodeTest > testDecodeFailOnInvalidVersionAndStatus() STARTED

FeatureZNodeTest > testDecodeFailOnInvalidVersionAndStatus() PASSED

ExtendedAclStoreTest > shouldHaveCorrectPaths() STARTED

ExtendedAclStoreTest > shouldHaveCorrectPaths() PASSED

ExtendedAclStoreTest > shouldRoundTripChangeNode() STARTED

ExtendedAclStoreTest > shouldRoundTripChangeNode() PASSED

ExtendedAclStoreTest > shouldThrowFromEncodeOnLiteral() STARTED

ExtendedAclStoreTest > shouldThrowFromEncodeOnLiteral() PASSED

ExtendedAclStoreTest > shouldThrowIfConstructedWithLiteral() STARTED

ExtendedAclStoreTest > shouldThrowIfConstructedWithLiteral() PASSED

ExtendedAclStoreTest > shouldWriteChangesToTheWritePath() STARTED

ExtendedAclStoreTest > shouldWriteChangesToTheWritePath() PASSED

ExtendedAclStoreTest > shouldHaveCorrectPatternType() STARTED

ExtendedAclStoreTest > shouldHaveCorrectPatternType() PASSED

DefaultMessageFormatterTest > [1] name=print nothing, 
record=ConsumerRe

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

[Apache Jenkins Server]

See 


Changes:

[github] MINOR: Add ClientQuotaMetadataManager for processing QuotaRecord  
(#10101)

[github] MINOR: Add RaftReplicaManager (#10069)


--
[...truncated 3.36 MB...]

LogValidatorTest > testInvalidTimestampExceptionHasBatchIndex() PASSED

LogValidatorTest > testRelativeOffsetAssignmentNonCompressedV1() STARTED

LogValidatorTest > testRelativeOffsetAssignmentNonCompressedV1() PASSED

LogValidatorTest > testRelativeOffsetAssignmentNonCompressedV2() STARTED

LogValidatorTest > testRelativeOffsetAssignmentNonCompressedV2() PASSED

LogValidatorTest > testControlRecordsNotAllowedFromClients() STARTED

LogValidatorTest > testControlRecordsNotAllowedFromClients() PASSED

LogValidatorTest > testRelativeOffsetAssignmentCompressedV1() STARTED

LogValidatorTest > testRelativeOffsetAssignmentCompressedV1() PASSED

LogValidatorTest > testRelativeOffsetAssignmentCompressedV2() STARTED

LogValidatorTest > testRelativeOffsetAssignmentCompressedV2() PASSED

LogValidatorTest > testOffsetAssignmentAfterDownConversionV2ToV1NonCompressed() 
STARTED

LogValidatorTest > testOffsetAssignmentAfterDownConversionV2ToV1NonCompressed() 
PASSED

LogValidatorTest > testMisMatchMagic() STARTED

LogValidatorTest > testMisMatchMagic() PASSED

LogValidatorTest > testLogAppendTimeNonCompressedV1() STARTED

LogValidatorTest > testLogAppendTimeNonCompressedV1() PASSED

LogValidatorTest > testLogAppendTimeNonCompressedV2() STARTED

LogValidatorTest > testLogAppendTimeNonCompressedV2() PASSED

LogValidatorTest > testOffsetAssignmentAfterDownConversionV2ToV0NonCompressed() 
STARTED

LogValidatorTest > testOffsetAssignmentAfterDownConversionV2ToV0NonCompressed() 
PASSED

LogValidatorTest > testControlRecordsNotCompressed() STARTED

LogValidatorTest > testControlRecordsNotCompressed() PASSED

LogValidatorTest > testInvalidCreateTimeNonCompressedV1() STARTED

LogValidatorTest > testInvalidCreateTimeNonCompressedV1() PASSED

LogValidatorTest > testInvalidCreateTimeNonCompressedV2() STARTED

LogValidatorTest > testInvalidCreateTimeNonCompressedV2() PASSED

LogValidatorTest > testCompressedBatchWithoutRecordsNotAllowed() STARTED

LogValidatorTest > testCompressedBatchWithoutRecordsNotAllowed() PASSED

LogValidatorTest > testOnlyOneBatch() STARTED

LogValidatorTest > testOnlyOneBatch() PASSED

LogValidatorTest > testBatchWithInvalidRecordsAndInvalidTimestamp() STARTED

LogValidatorTest > testBatchWithInvalidRecordsAndInvalidTimestamp() PASSED

LogValidatorTest > testAllowMultiBatch() STARTED

LogValidatorTest > testAllowMultiBatch() PASSED

LogValidatorTest > testInvalidOffsetRangeAndRecordCount() STARTED

LogValidatorTest > testInvalidOffsetRangeAndRecordCount() PASSED

LogValidatorTest > testLogAppendTimeWithoutRecompressionV1() STARTED

LogValidatorTest > testLogAppendTimeWithoutRecompressionV1() PASSED

LogValidatorTest > testLogAppendTimeWithoutRecompressionV2() STARTED

LogValidatorTest > testLogAppendTimeWithoutRecompressionV2() PASSED

LogValidatorTest > testUncompressedBatchWithoutRecordsNotAllowed() STARTED

LogValidatorTest > testUncompressedBatchWithoutRecordsNotAllowed() PASSED

LogValidatorTest > testOffsetAssignmentAfterDownConversionV1ToV0NonCompressed() 
STARTED

LogValidatorTest > testOffsetAssignmentAfterDownConversionV1ToV0NonCompressed() 
PASSED

LogValidatorTest > testAbsoluteOffsetAssignmentNonCompressed() STARTED

LogValidatorTest > testAbsoluteOffsetAssignmentNonCompressed() PASSED

LogValidatorTest > testOffsetAssignmentAfterDownConversionV2ToV1Compressed() 
STARTED

LogValidatorTest > testOffsetAssignmentAfterDownConversionV2ToV1Compressed() 
PASSED

LogValidatorTest > testOffsetAssignmentAfterDownConversionV1ToV0Compressed() 
STARTED

LogValidatorTest > testOffsetAssignmentAfterDownConversionV1ToV0Compressed() 
PASSED

LogValidatorTest > testOffsetAssignmentAfterUpConversionV0ToV2Compressed() 
STARTED

LogValidatorTest > testOffsetAssignmentAfterUpConversionV0ToV2Compressed() 
PASSED

LogValidatorTest > testNonCompressedV1() STARTED

LogValidatorTest > testNonCompressedV1() PASSED

LogValidatorTest > testNonCompressedV2() STARTED

LogValidatorTest > testNonCompressedV2() PASSED

LogValidatorTest > testOffsetAssignmentAfterUpConversionV1ToV2NonCompressed() 
STARTED

LogValidatorTest > testOffsetAssignmentAfterUpConversionV1ToV2NonCompressed() 
PASSED

LogValidatorTest > testInvalidCreateTimeCompressedV1() STARTED

LogValidatorTest > testInvalidCreateTimeCompressedV1() PASSED

LogValidatorTest > testInvalidCreateTimeCompressedV2() STARTED

LogValidatorTest > testInvalidCreateTimeCompressedV2() PASSED

LogValidatorTest > testNonIncreasingOffsetRecordBatchHasMetricsLogged() STARTED

LogValidatorTest > testNonIncreasingOffsetRecordBatchHasMetricsLogged() PASSED

LogValidatorTest > testRecompressionV1() STARTED

LogValidatorTest > testRecompressionV1() PASSED

LogValidatorTest > testR

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

[Apache Jenkins Server]

See 


Changes:

[github] MINOR: Add ClientQuotaMetadataManager for processing QuotaRecord  
(#10101)

[github] MINOR: Add RaftReplicaManager (#10069)


--
[...truncated 3.43 MB...]

OperationTest > testJavaConversions() PASSED

AclEntryTest > testAclJsonConversion() STARTED

AclEntryTest > testAclJsonConversion() PASSED

MetricsDuringTopicCreationDeletionTest > testMetricsDuringTopicCreateDelete() 
STARTED

MetricsDuringTopicCreationDeletionTest > testMetricsDuringTopicCreateDelete() 
PASSED

UncleanLeaderElectionTest > testTopicUncleanLeaderElectionEnable() STARTED

UncleanLeaderElectionTest > testTopicUncleanLeaderElectionEnable() PASSED

UncleanLeaderElectionTest > testUncleanLeaderElectionEnabled() STARTED

UncleanLeaderElectionTest > testUncleanLeaderElectionEnabled() PASSED

UncleanLeaderElectionTest > testUncleanLeaderElectionDisabled() STARTED

UncleanLeaderElectionTest > testUncleanLeaderElectionDisabled() PASSED

UncleanLeaderElectionTest > testUncleanLeaderElectionInvalidTopicOverride() 
STARTED

UncleanLeaderElectionTest > testUncleanLeaderElectionInvalidTopicOverride() 
PASSED

UncleanLeaderElectionTest > testUncleanLeaderElectionEnabledByTopicOverride() 
STARTED

UncleanLeaderElectionTest > testUncleanLeaderElectionEnabledByTopicOverride() 
PASSED

UncleanLeaderElectionTest > testUncleanLeaderElectionDisabledByTopicOverride() 
STARTED

UncleanLeaderElectionTest > testUncleanLeaderElectionDisabledByTopicOverride() 
PASSED

PartitionTest > testMakeLeaderDoesNotUpdateEpochCacheForOldFormats() STARTED

PartitionTest > testMakeLeaderDoesNotUpdateEpochCacheForOldFormats() PASSED

PartitionTest > testIsrExpansion() STARTED

PartitionTest > testIsrExpansion() PASSED

PartitionTest > testReadRecordEpochValidationForLeader() STARTED

PartitionTest > testReadRecordEpochValidationForLeader() PASSED

PartitionTest > testAlterIsrUnknownTopic() STARTED

PartitionTest > testAlterIsrUnknownTopic() PASSED

PartitionTest > testIsrNotShrunkIfUpdateFails() STARTED

PartitionTest > testIsrNotShrunkIfUpdateFails() PASSED

PartitionTest > testFetchOffsetForTimestampEpochValidationForFollower() STARTED

PartitionTest > testFetchOffsetForTimestampEpochValidationForFollower() PASSED

PartitionTest > testIsrNotExpandedIfUpdateFails() STARTED

PartitionTest > testIsrNotExpandedIfUpdateFails() PASSED

PartitionTest > testLogConfigDirtyAsBrokerUpdated() STARTED

PartitionTest > testLogConfigDirtyAsBrokerUpdated() PASSED

PartitionTest > testAddAndRemoveMetrics() STARTED

PartitionTest > testAddAndRemoveMetrics() PASSED

PartitionTest > testListOffsetIsolationLevels() STARTED

PartitionTest > testListOffsetIsolationLevels() PASSED

PartitionTest > testAppendRecordsAsFollowerBelowLogStartOffset() STARTED

PartitionTest > testAppendRecordsAsFollowerBelowLogStartOffset() PASSED

PartitionTest > testFetchLatestOffsetIncludesLeaderEpoch() STARTED

PartitionTest > testFetchLatestOffsetIncludesLeaderEpoch() PASSED

PartitionTest > testUnderReplicatedPartitionsCorrectSemantics() STARTED

PartitionTest > testUnderReplicatedPartitionsCorrectSemantics() PASSED

PartitionTest > testFetchOffsetSnapshotEpochValidationForFollower() STARTED

PartitionTest > testFetchOffsetSnapshotEpochValidationForFollower() PASSED

PartitionTest > testMaybeShrinkIsr() STARTED

PartitionTest > testMaybeShrinkIsr() PASSED

PartitionTest > testLogConfigNotDirty() STARTED

PartitionTest > testLogConfigNotDirty() PASSED

PartitionTest > testMonotonicOffsetsAfterLeaderChange() STARTED

PartitionTest > testMonotonicOffsetsAfterLeaderChange() PASSED

PartitionTest > testUpdateAssignmentAndIsr() STARTED

PartitionTest > testUpdateAssignmentAndIsr() PASSED

PartitionTest > testMakeFollowerWithNoLeaderIdChange() STARTED

PartitionTest > testMakeFollowerWithNoLeaderIdChange() PASSED

PartitionTest > testAppendRecordsToFollowerWithNoReplicaThrowsException() 
STARTED

PartitionTest > testAppendRecordsToFollowerWithNoReplicaThrowsException() PASSED

PartitionTest > 
testFollowerDoesNotJoinISRUntilCaughtUpToOffsetWithinCurrentLeaderEpoch() 
STARTED

PartitionTest > 
testFollowerDoesNotJoinISRUntilCaughtUpToOffsetWithinCurrentLeaderEpoch() PASSED

PartitionTest > testSingleInFlightAlterIsr() STARTED

PartitionTest > testSingleInFlightAlterIsr() PASSED

PartitionTest > testShouldNotShrinkIsrIfFollowerCaughtUpToLogEnd() STARTED

PartitionTest > testShouldNotShrinkIsrIfFollowerCaughtUpToLogEnd() PASSED

PartitionTest > testFetchOffsetSnapshotEpochValidationForLeader() STARTED

PartitionTest > testFetchOffsetSnapshotEpochValidationForLeader() PASSED

PartitionTest > testOffsetForLeaderEpochValidationForLeader() STARTED

PartitionTest > testOffsetForLeaderEpochValidationForLeader() PASSED

PartitionTest > testAtMinIsr() STARTED

PartitionTest > testAtMinIsr() PASSED

PartitionTest > testAlterIsrInvalidVersion() STARTED

PartitionTest > testAl

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

[Apache Jenkins Server]

See 


Changes:

[github] MINOR: Add ClientQuotaMetadataManager for processing QuotaRecord  
(#10101)

[github] MINOR: Add RaftReplicaManager (#10069)


--
[...truncated 3.61 MB...]

AclAuthorizerTest > testNoAclFoundOverride() STARTED

AclAuthorizerTest > testNoAclFoundOverride() PASSED

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 > 
testAuthorizeByResourceTyp

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

[Apache Jenkins Server]

See 


Changes:

[github] MINOR: Prevent creating partition.metadata until ID can be written 
(#10041)


--
[...truncated 3.58 MB...]

PlaintextAdminIntegrationTest > testValidIncrementalAlterConfigs() PASSED

PlaintextAdminIntegrationTest > testInvalidIncrementalAlterConfigs() STARTED

PlaintextAdminIntegrationTest > testInvalidIncrementalAlterConfigs() PASSED

PlaintextAdminIntegrationTest > testSeekAfterDeleteRecords() STARTED

PlaintextAdminIntegrationTest > testSeekAfterDeleteRecords() PASSED

PlaintextAdminIntegrationTest > testCallInFlightTimeouts() STARTED

PlaintextAdminIntegrationTest > testCallInFlightTimeouts() PASSED

PlaintextAdminIntegrationTest > testNullConfigs() STARTED

PlaintextAdminIntegrationTest > testNullConfigs() PASSED

PlaintextAdminIntegrationTest > testDescribeConfigsForTopic() STARTED

PlaintextAdminIntegrationTest > testDescribeConfigsForTopic() PASSED

PlaintextAdminIntegrationTest > testConsumerGroups() STARTED

PlaintextAdminIntegrationTest > testConsumerGroups() PASSED

PlaintextAdminIntegrationTest > testElectUncleanLeadersWhenNoLiveBrokers() 
STARTED

PlaintextAdminIntegrationTest > testElectUncleanLeadersWhenNoLiveBrokers() 
PASSED

PlaintextAdminIntegrationTest > 
testCreateExistingTopicsThrowTopicExistsException() STARTED

PlaintextAdminIntegrationTest > 
testCreateExistingTopicsThrowTopicExistsException() PASSED

ClientIdQuotaTest > testProducerConsumerOverrideLowerQuota() STARTED

ClientIdQuotaTest > testProducerConsumerOverrideLowerQuota() PASSED

ClientIdQuotaTest > testProducerConsumerOverrideUnthrottled() STARTED

ClientIdQuotaTest > testProducerConsumerOverrideUnthrottled() PASSED

ClientIdQuotaTest > testThrottledProducerConsumer() STARTED

ClientIdQuotaTest > testThrottledProducerConsumer() PASSED

ClientIdQuotaTest > testQuotaOverrideDelete() STARTED

ClientIdQuotaTest > testQuotaOverrideDelete() PASSED

ClientIdQuotaTest > testThrottledRequest() STARTED

ClientIdQuotaTest > testThrottledRequest() PASSED

ProducerCompressionTest > [1] compression=none STARTED

ProducerCompressionTest > [1] compression=none PASSED

ProducerCompressionTest > [2] compression=gzip STARTED

ProducerCompressionTest > [2] compression=gzip PASSED

ProducerCompressionTest > [3] compression=snappy STARTED

ProducerCompressionTest > [3] compression=snappy PASSED

ProducerCompressionTest > [4] compression=lz4 STARTED

ProducerCompressionTest > [4] compression=lz4 PASSED

ProducerCompressionTest > [5] compression=zstd STARTED

ProducerCompressionTest > [5] compression=zstd PASSED

DescribeAuthorizedOperationsTest > testClusterAuthorizedOperations() STARTED

DescribeAuthorizedOperationsTest > testClusterAuthorizedOperations() PASSED

DescribeAuthorizedOperationsTest > testTopicAuthorizedOperations() STARTED

DescribeAuthorizedOperationsTest > testTopicAuthorizedOperations() PASSED

DescribeAuthorizedOperationsTest > testConsumerGroupAuthorizedOperations() 
STARTED

DescribeAuthorizedOperationsTest > testConsumerGroupAuthorizedOperations() 
PASSED

GroupCoordinatorIntegrationTest > 
testGroupCoordinatorPropagatesOffsetsTopicCompressionCodec() STARTED

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

MinIsrConfigTest > testDefaultKafkaConfig() STARTED

MinIsrConfigTest > testDefaultKafkaConfig() 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@510d80e7, value = [B@34f83951), 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@510d80e7, value = [B@34f83951), properti

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

[Apache Jenkins Server]

See 


Changes:

[github] MINOR: Prevent creating partition.metadata until ID can be written 
(#10041)


--
[...truncated 3.62 MB...]

AclAuthorizerTest > testNoAclFoundOverride() STARTED

AclAuthorizerTest > testNoAclFoundOverride() PASSED

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

AuthorizerInterf

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

[Apache Jenkins Server]

See 


Changes:

[github] MINOR: Prevent creating partition.metadata until ID can be written 
(#10041)


--
[...truncated 3.45 MB...]
SocketServerTest > testConnectionRatePerIp() PASSED

SocketServerTest > processCompletedSendException() STARTED

SocketServerTest > processCompletedSendException() PASSED

SocketServerTest > processDisconnectedException() STARTED

SocketServerTest > processDisconnectedException() PASSED

SocketServerTest > closingChannelWithBufferedReceives() STARTED

SocketServerTest > closingChannelWithBufferedReceives() PASSED

SocketServerTest > sendCancelledKeyException() STARTED

SocketServerTest > sendCancelledKeyException() PASSED

SocketServerTest > processCompletedReceiveException() STARTED

SocketServerTest > processCompletedReceiveException() PASSED

SocketServerTest > testControlPlaneAsPrivilegedListener() STARTED

SocketServerTest > testControlPlaneAsPrivilegedListener() PASSED

SocketServerTest > closingChannelSendFailure() STARTED

SocketServerTest > closingChannelSendFailure() PASSED

SocketServerTest > idleExpiryWithBufferedReceives() STARTED

SocketServerTest > idleExpiryWithBufferedReceives() PASSED

SocketServerTest > testSocketsCloseOnShutdown() STARTED

SocketServerTest > testSocketsCloseOnShutdown() PASSED

SocketServerTest > 
testNoOpActionResponseWithThrottledChannelWhereThrottlingAlreadyDone() STARTED

SocketServerTest > 
testNoOpActionResponseWithThrottledChannelWhereThrottlingAlreadyDone() PASSED

SocketServerTest > pollException() STARTED

SocketServerTest > pollException() PASSED

SocketServerTest > closingChannelWithBufferedReceivesFailedSend() STARTED

SocketServerTest > closingChannelWithBufferedReceivesFailedSend() PASSED

SocketServerTest > remoteCloseWithBufferedReceives() STARTED

SocketServerTest > remoteCloseWithBufferedReceives() PASSED

SocketServerTest > testThrottledSocketsClosedOnShutdown() STARTED

SocketServerTest > testThrottledSocketsClosedOnShutdown() PASSED

SocketServerTest > closingChannelWithCompleteAndIncompleteBufferedReceives() 
STARTED

SocketServerTest > closingChannelWithCompleteAndIncompleteBufferedReceives() 
PASSED

SocketServerTest > testInterBrokerListenerAsPrivilegedListener() STARTED

SocketServerTest > testInterBrokerListenerAsPrivilegedListener() PASSED

SocketServerTest > testSslSocketServer() STARTED

SocketServerTest > testSslSocketServer() PASSED

SocketServerTest > testDisabledRequestIsRejected() STARTED

SocketServerTest > testDisabledRequestIsRejected() PASSED

SocketServerTest > tooBigRequestIsRejected() STARTED

SocketServerTest > tooBigRequestIsRejected() PASSED

SocketServerTest > 
testNoOpActionResponseWithThrottledChannelWhereThrottlingInProgress() STARTED

SocketServerTest > 
testNoOpActionResponseWithThrottledChannelWhereThrottlingInProgress() PASSED

KafkaTimerTest > testKafkaTimer() STARTED

KafkaTimerTest > testKafkaTimer() PASSED

LinuxIoMetricsCollectorTest > testReadProcFile() STARTED

LinuxIoMetricsCollectorTest > testReadProcFile() PASSED

LinuxIoMetricsCollectorTest > testUnableToReadNonexistentProcFile() STARTED

LinuxIoMetricsCollectorTest > testUnableToReadNonexistentProcFile() PASSED

TransactionsWithMaxInFlightOneTest > 
testTransactionalProducerSingleBrokerMaxInFlightOne() STARTED

TransactionsWithMaxInFlightOneTest > 
testTransactionalProducerSingleBrokerMaxInFlightOne() 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@71668b23, value = [B@2741d33e), 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@71668b23, value = [B@2741d33e), 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@9bdc750, value = [B@20cc3d7a), properties=Map(print.key -> true, print.value 
-> false), expected=someKey
 STARTED

DefaultMessageFormatterTest > [2] name=print key, record=ConsumerRecord(topic = 
someTopic, partitio

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

[Apache Jenkins Server]

See 


Changes:

[Colin McCabe] MINOR: Add ClientQuotaMetadataManager for processing QuotaRecord 
 (#10101)

[Colin McCabe] MINOR: Add RaftReplicaManager (#10069)


--
[...truncated 7.19 MB...]
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

ConnectionQuotasTest > 
testListenerConnectionRateLimitWhenActualRateAboveLimit() PASSED

ConnectionQuotasTest > testEnforcedIpConnectionRateQuotaUpdate() STARTED

ConnectionQuotasTest > testEnforcedIpConnectionRateQuotaUpdate() PASSED

ConnectionQuotasTest > testMaxBrokerConnectionRateReconfiguration() STARTED

ConnectionQuotasTest > testMaxBrokerConnectionRateReconfiguration() PASSED

ConnectionQuotasTest > 
testListenerConnectionRateLimitWhenActualRateBelowLimit() STARTED

ConnectionQuotasTest > 
testListenerConnectionRateLimitWhenActualRateBelowLimit() PASSED

ConnectionQuotasTest > testFailWhenNoListeners() STARTED

ConnectionQuotasTest > testFailWhenNoListeners() PASSED

ConnectionQuotasTest > testIpConnectionRateWhenActualRateAboveLimit() STARTED

ConnectionQuotasTest > testIpConnectionRateWhenActualRateAboveLimit() PASSED

RequestConvertToJsonTest > testAllResponseTypesHandled() STARTED

RequestConvertToJsonTest > testAllResponseTypesHandled() PASSED

RequestConvertToJsonTest > testAllRequestTypesHandled() STARTED

RequestConvertToJsonTest > testAllRequestTypesHandled() PASSED

RequestConvertToJsonTest > testRequestDescMetrics() STARTED

RequestConvertToJsonTest > testRequestDescMetrics() PASSED

RequestConvertToJsonTest > testClientInfoNode() STARTED

RequestConvertToJsonTest > testClientInfoNode() PASSED

RequestConvertToJsonTest > testRequestDesc() STARTED

RequestConvertToJsonTest > testRequestDesc() PASSED

RequestConvertToJsonTest > testRequestHeaderNode() STARTED

RequestConvertToJsonTest > testRequestHeaderNode() PASSED

RequestChannelTest > testNonAlterRequestsNotTransformed() STARTED

RequestChannelTest > testNonAlterRequestsNotTransformed() PASSED

RequestChannelTest > testAlterRequests() STARTED

RequestChannelTest > testAlterRequests() PASSED

RequestChannelTest > testJsonRequests() STARTED

RequestChannelTest > testJsonRequests() PASSED

RequestChannelTest > testIncrementalAlterRequests() STARTED

RequestChannelTest > testIncrementalAlterRequests() PASSED

ZkNodeChangeNotificationListenerTest > testProcessNotification() STARTED

ZkNodeChangeNotificationListenerTest > testProcessNotification() PASSED

ZkNodeChangeNotificationListenerTest > testSwallowsProcessorException() STARTED

ZkNodeChangeNotificationListenerTest > testSwallowsProcessorException() PASSED

InterBrokerSendThreadTest > shouldCreateClientRequestAndSendWhenNodeIsReady() 
STARTED

InterBrokerSendThreadTest > shouldCreateClientRequestAndSendWhenNodeIsReady() 
PASSED

InterBrokerSendThreadTest > testFailingExpiredRequests() STARTED

InterBrokerSendThreadTest > testFailingExpiredRequests() PASSED

InterBrokerSendThreadTest > 
shouldCallCompletionHandlerWithDisconnectedResponseWhenNodeNotReady() STARTED

InterBrokerSendThreadTest > 
shouldCallCompletionHandlerWithDisconnectedResponseWhenNodeNotReady() PASSED

InterBrokerSendThreadTest > shouldNotSendAnythingWhenNoRequests() STARTED

InterBrokerSendThreadTest > shouldNotSendAnythingWhenNoRequests() PASSED

DefaultMessageFormatterTest > [1] name=print nothing, 
record=ConsumerRecord(topic = someTopic, partition = 9, leaderEpoch = null, 
offset = 9876, CreateTime = 1234, serialized key size = 0, serialized value

[jira] [Resolved] (KAFKA-12182) Kafka connector is failing due to ' OffsetStorageWriter is already flushing' error

[Chris Egerton (Jira)]

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

Chris Egerton resolved KAFKA-12182.
---
Resolution: Duplicate

> Kafka connector is failing due to ' OffsetStorageWriter is already flushing' 
> error
> --
>
> Key: KAFKA-12182
> URL: https://issues.apache.org/jira/browse/KAFKA-12182
> Project: Kafka
>  Issue Type: Bug
>  Components: KafkaConnect
> Environment: QAS
>Reporter: Fátima Galera
>Priority: Major
>
> Hi kafka support
>  
> We have a connector which is failing with below error
>  
> "state": "FAILED",
> "worker_id": "xx:8083",
> "trace": "org.apache.kafka.connect.errors.ConnectException: 
> OffsetStorageWriter is already flushing\n\tat 
> org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:111)\n\tat
>  
> org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:410)\n\tat
>  
> org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:239)\n\tat
>  org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:175)\n\tat 
> org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:219)\n\tat 
> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)\n\tat 
> java.util.concurrent.FutureTask.run(FutureTask.java:266)\n\tat 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)\n\tat
>  
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\n\tat
>  java.lang.Thread.run(Thread.java:748)\n"
>  
> I have read below article about this issue, but this is old. Could you please 
> let us know if we should implement these parameters?
>  
> [https://stackoverflow.com/questions/55839310/debezium-is-failing-to-snapshot-big-table-size]
>  
> Best regards and thanks
> Fátima



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

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

[Apache Jenkins Server]

See 


Changes:

[github] MINOR: Prevent creating partition.metadata until ID can be written 
(#10100)


--
[...truncated 3.37 MB...]

LogManagerTest > testConfigChangeGetsCleanedUp() PASSED

LogManagerTest > testTwoLogManagersUsingSameDirFails() STARTED

LogManagerTest > testTwoLogManagersUsingSameDirFails() PASSED

LogManagerTest > testLeastLoadedAssignment() STARTED

LogManagerTest > testLeastLoadedAssignment() PASSED

LogManagerTest > testCleanupExpiredSegments() STARTED

LogManagerTest > testCleanupExpiredSegments() PASSED

LogManagerTest > testCheckpointRecoveryPoints() STARTED

LogManagerTest > testCheckpointRecoveryPoints() PASSED

LogManagerTest > testBrokerConfigChangeDeliveredToAllLogs() STARTED

LogManagerTest > testBrokerConfigChangeDeliveredToAllLogs() PASSED

LogManagerTest > testMetricsAreRemovedWhenMovingCurrentToFutureLog() STARTED

LogManagerTest > testMetricsAreRemovedWhenMovingCurrentToFutureLog() PASSED

LogManagerTest > testCheckpointForOnlyAffectedLogs() STARTED

LogManagerTest > testCheckpointForOnlyAffectedLogs() PASSED

LogManagerTest > testTimeBasedFlush() STARTED

LogManagerTest > testTimeBasedFlush() PASSED

LogManagerTest > testCreateLog() STARTED

LogManagerTest > testCreateLog() PASSED

LogManagerTest > testDoesntCleanLogsWithCompactPolicy() STARTED

LogManagerTest > testDoesntCleanLogsWithCompactPolicy() PASSED

LogManagerTest > testRecoveryDirectoryMappingWithTrailingSlash() STARTED

LogManagerTest > testRecoveryDirectoryMappingWithTrailingSlash() PASSED

LogManagerTest > testCreateAndDeleteOverlyLongTopic() STARTED

LogManagerTest > testCreateAndDeleteOverlyLongTopic() PASSED

LogManagerTest > testDoesntCleanLogsWithCompactDeletePolicy() STARTED

LogManagerTest > testDoesntCleanLogsWithCompactDeletePolicy() PASSED

LogManagerTest > testConfigChangesWithNoLogGettingInitialized() STARTED

LogManagerTest > testConfigChangesWithNoLogGettingInitialized() PASSED

LogCleanerParameterizedIntegrationTest > [1] codec=NONE STARTED

LogCleanerParameterizedIntegrationTest > [1] codec=NONE PASSED

LogCleanerParameterizedIntegrationTest > [2] codec=GZIP STARTED

LogCleanerParameterizedIntegrationTest > [2] codec=GZIP PASSED

LogCleanerParameterizedIntegrationTest > [3] codec=SNAPPY STARTED

LogCleanerParameterizedIntegrationTest > [3] codec=SNAPPY PASSED

LogCleanerParameterizedIntegrationTest > [4] codec=LZ4 STARTED

LogCleanerParameterizedIntegrationTest > [4] codec=LZ4 PASSED

LogCleanerParameterizedIntegrationTest > [5] codec=ZSTD STARTED

LogCleanerParameterizedIntegrationTest > [5] codec=ZSTD PASSED

LogCleanerParameterizedIntegrationTest > [1] codec=NONE STARTED

LogCleanerParameterizedIntegrationTest > [1] codec=NONE PASSED

LogCleanerParameterizedIntegrationTest > [2] codec=GZIP STARTED

LogCleanerParameterizedIntegrationTest > [2] codec=GZIP PASSED

LogCleanerParameterizedIntegrationTest > [3] codec=SNAPPY STARTED

LogCleanerParameterizedIntegrationTest > [3] codec=SNAPPY PASSED

LogCleanerParameterizedIntegrationTest > [4] codec=LZ4 STARTED

LogCleanerParameterizedIntegrationTest > [4] codec=LZ4 PASSED

LogCleanerParameterizedIntegrationTest > [1] codec=NONE STARTED

LogCleanerParameterizedIntegrationTest > [1] codec=NONE PASSED

LogCleanerParameterizedIntegrationTest > [2] codec=GZIP STARTED

LogCleanerParameterizedIntegrationTest > [2] codec=GZIP PASSED

LogCleanerParameterizedIntegrationTest > [3] codec=SNAPPY STARTED

LogCleanerParameterizedIntegrationTest > [3] codec=SNAPPY PASSED

LogCleanerParameterizedIntegrationTest > [4] codec=LZ4 STARTED

LogCleanerParameterizedIntegrationTest > [4] codec=LZ4 PASSED

LogCleanerParameterizedIntegrationTest > [5] codec=ZSTD STARTED

LogCleanerParameterizedIntegrationTest > [5] codec=ZSTD PASSED

LogCleanerParameterizedIntegrationTest > [1] codec=NONE STARTED

LogCleanerParameterizedIntegrationTest > [1] codec=NONE PASSED

LogCleanerParameterizedIntegrationTest > [2] codec=GZIP STARTED

LogCleanerParameterizedIntegrationTest > [2] codec=GZIP PASSED

LogCleanerParameterizedIntegrationTest > [3] codec=SNAPPY STARTED

LogCleanerParameterizedIntegrationTest > [3] codec=SNAPPY PASSED

LogCleanerParameterizedIntegrationTest > [4] codec=LZ4 STARTED

LogCleanerParameterizedIntegrationTest > [4] codec=LZ4 PASSED

LogCleanerParameterizedIntegrationTest > [5] codec=ZSTD STARTED

LogCleanerParameterizedIntegrationTest > [5] codec=ZSTD PASSED

LogCleanerParameterizedIntegrationTest > [1] codec=NONE STARTED

LogCleanerParameterizedIntegrationTest > [1] codec=NONE PASSED

LogCleanerParameterizedIntegrationTest > [2] codec=GZIP STARTED

LogCleanerParameterizedIntegrationTest > [2] codec=GZIP PASSED

LogCleanerParameterizedIntegrationTest > [3] codec=SNAPPY STARTED

LogCleanerParameterizedIntegrationTest > [3] codec=SNAPPY PASSED

LogCleanerParameterizedIntegrationTest > [4] codec=LZ4 STARTED

LogCleanerParameterizedInteg

Jenkins build is back to normal : Kafka » kafka-2.7-jdk8 #118

[Apache Jenkins Server]

See