Hi Greg,

The fix for 14929 has already been included as part of this pr :
https://github.com/apache/kafka/pull/13594

I can create a separate pr just for that flaky test if needed. Let me know .

Sagar.

On Sat, 22 Apr 2023 at 3:20 AM, Greg Harris <greg.har...@aiven.io.invalid>
wrote:

> Hey all,
>
> We just landed a fix for https://issues.apache.org/jira/browse/KAFKA-14905
> which was causing all of
> those MirrorConnectorsWithCustomForwardingAdminIntegrationTest failures,
> and we will monitor the build for any re-occurrances.
> Unfortunately we discovered another test flake that was introduced recently
> but that should have a straightforward resolution:
> https://issues.apache.org/jira/browse/KAFKA-14929
> Thanks Ismael for merging a fix for
> https://issues.apache.org/jira/browse/KAFKA-8115 but it appears that there
> is still more investigation needed there, as the test is still failing
> occasionally.
>
> Thanks,
> Greg
>
> On Fri, Apr 14, 2023 at 12:18 PM Ismael Juma <ism...@juma.me.uk> wrote:
>
> > Thanks Greg! I really appreciate the help.
> >
> > Ismael
> >
> > On Fri, Apr 14, 2023 at 12:08 PM Greg Harris
> <greg.har...@aiven.io.invalid
> > >
> > wrote:
> >
> > > Hey Ismael,
> > >
> > > We're working to stabilize the Connect/MM2 tests with the following
> > issues:
> > >
> > > * https://issues.apache.org/jira/browse/KAFKA-14905 to address
> > > MirrorConectorsWithCustomForwardingAdminIntegrationTest with tentative
> > open
> > > PR
> > > * https://issues.apache.org/jira/browse/KAFKA-14901 to address
> > > ExactlyOnceSourceIntegrationTest caused by an (apparent) kafka bug
> > >
> > > Looking at the other failures in Connect/MM2 for that build in
> > particular,
> > > it appears that most of them include Embedded Kafka not coming
> > up/shutting
> > > down cleanly:
> > > * MirrorConnectorsIntegrationBaseTest
> > > * MirrorConnectorsIntegrationExactlyOnceTest
> > > * MirrorConnectorsIntegrationSSLTest
> > > * ConnectorClientPolicyIntegrationTest
> > > * ConnectorTopicsIntegrationTest
> > > * ExactlyOnceSourceIntegrationTest
> > > * OffsetsApiIntegrationTest
> > > I'll start investigating these failures to learn more.
> > >
> > > I also have a few older flaky test improvements that have not been
> > reviewed
> > > or merged yet:
> > > * https://issues.apache.org/jira/browse/KAFKA-8115 to
> > > address CoordinatorTest (reappeared in the linked build)
> > > * https://issues.apache.org/jira/browse/KAFKA-14345 to address
> > > (Dynamic)ConnectionQuotaTest
> > >
> > > It also appears that the flakey AuthorizerTest should be addressed by
> > > https://github.com/apache/kafka/pull/13543 which is on trunk now but
> > > wasn't
> > > at the time of the above run.
> > >
> > > Thanks,
> > > Greg
> > >
> > > On Fri, Apr 14, 2023 at 10:25 AM Ismael Juma <ism...@juma.me.uk>
> wrote:
> > >
> > > > Thanks Justine!
> > > >
> > > > Ismael
> > > >
> > > > On Fri, Apr 14, 2023 at 9:53 AM Justine Olshan
> > > > <jols...@confluent.io.invalid>
> > > > wrote:
> > > >
> > > > > Hey Ismael -- thanks for bringing this up.
> > > > > I've filed https://issues.apache.org/jira/browse/KAFKA-14904 and
> am
> > > > > working
> > > > > on it now.
> > > > >
> > > > > I hope the other tests get fixed soon.
> > > > >
> > > > > On Fri, Apr 14, 2023 at 6:47 AM Ismael Juma <ism...@juma.me.uk>
> > wrote:
> > > > >
> > > > > > Hi team,
> > > > > >
> > > > > > It looks like there are a lot of test failures in the master
> > branch.
> > > I
> > > > > > don't know which commits introduced them, but can you please
> check
> > if
> > > > > > commit(s) you merged or contributed are the reason and fix it
> asap?
> > > If
> > > > > it's
> > > > > > easy to fix the tests, let's do that - otherwise we should revert
> > the
> > > > > > faulty commit. And let's please be more careful going forward
> when
> > it
> > > > > comes
> > > > > > to the PRs we merge.
> > > > > >
> > > > > > An example from one of the builds, but there are many like this:
> > > > > >
> > > > > > Build / JDK 17 and Scala 2.13 /
> > > > > > kafka.api.TransactionsBounceTest.testWithGroupMetadata()
> > > > > > Build / JDK 17 and Scala 2.13 /
> > > > > > kafka.api.TransactionsBounceTest.testWithGroupId()
> > > > > > Build / JDK 17 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> kafka.security.authorizer.AuthorizerTest.testAllowAllAccess(String).quorum=kraft
> > > > > > Build / JDK 17 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> kafka.security.authorizer.AuthorizerTest.testAuthorizeThrowsOnNonLiteralResource(String).quorum=kraft
> > > > > > Build / JDK 8 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> kafka.admin.TopicCommandIntegrationTest.testDescribeUnderMinIsrPartitionsMixed(String).quorum=zk
> > > > > > Build / JDK 8 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> kafka.security.authorizer.AuthorizerTest.testAllowAllAccess(String).quorum=kraft
> > > > > > Build / JDK 8 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> kafka.security.authorizer.AuthorizerTest.testDeleteAclOnPrefixedResource(String).quorum=kraft
> > > > > > Build / JDK 8 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> kafka.security.authorizer.AuthorizerTest.testNoAclFoundOverride(String).quorum=kraft
> > > > > > Build / JDK 8 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> kafka.security.authorizer.AuthorizerTest.testAuthorizeThrowsOnNonLiteralResource(String).quorum=kraft
> > > > > > Build / JDK 8 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> kafka.security.authorizer.AuthorizerTest.testGetAclsPrincipal(String).quorum=kraft
> > > > > > Build / JDK 8 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> kafka.security.authorizer.AuthorizerTest.testAllowAllAccess(String).quorum=kraft
> > > > > > Build / JDK 8 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> kafka.security.authorizer.AuthorizerTest.testAuthorizeThrowsOnNonLiteralResource(String).quorum=kraft
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationBaseTest.testSyncTopicConfigs()
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationBaseTest.testRestartReplication()
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationBaseTest.testOneWayReplicationWithFrequentOffsetSyncs()
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationExactlyOnceTest.testReplication()
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationExactlyOnceTest.testReplicationWithEmptyPartition()
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationExactlyOnceTest.testReplicateSourceDefault()
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationExactlyOnceTest.testOffsetSyncsTopicsOnTarget()
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationExactlyOnceTest.testReplicateTargetDefault()
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationExactlyOnceTest.testNoCheckpointsIfNoRecordsAreMirrored()
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationExactlyOnceTest.testOneWayReplicationWithAutoOffsetSync()
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationExactlyOnceTest.testSyncTopicConfigs()
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationSSLTest.testReplication()
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationSSLTest.testReplicationWithEmptyPartition()
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationSSLTest.testReplicateSourceDefault()
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationSSLTest.testOffsetSyncsTopicsOnTarget()
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationSSLTest.testReplicateTargetDefault()
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationSSLTest.testNoCheckpointsIfNoRecordsAreMirrored()
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationSSLTest.testSyncTopicConfigs()
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationTransactionsTest.testReplicateSourceDefault()
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.integration.ConnectorClientPolicyIntegrationTest.testCreateWithOverridesForNonePolicy
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.integration.ConnectorClientPolicyIntegrationTest.testCreateWithAllowedOverridesForDefaultPolicy
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.integration.ConnectorClientPolicyIntegrationTest.testCreateWithNoAllowedOverridesForNonePolicy
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.integration.ConnectorTopicsIntegrationTest.testGetActiveTopics
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.integration.ConnectorTopicsIntegrationTest.testTopicTrackingResetIsDisabled
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.integration.ConnectorTopicsIntegrationTest.testTopicTrackingIsDisabled
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.integration.ExactlyOnceSourceIntegrationTest.testConnectorReconfiguration
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.integration.ExactlyOnceSourceIntegrationTest.testSeparateOffsetsTopic
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.integration.OffsetsApiIntegrationTest.testGetSinkConnectorOffsets
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.integration.OffsetsApiIntegrationTest.testGetNonExistentConnectorOffsets
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.integration.OffsetsApiIntegrationTest.testGetSinkConnectorOffsetsOverriddenConsumerGroupId
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.integration.OffsetsApiIntegrationTest.testGetSourceConnectorOffsets
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.integration.OffsetsApiIntegrationTest.testGetSinkConnectorOffsetsDifferentKafkaClusterTargeted
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.integration.OffsetsApiIntegrationTest.testGetSourceConnectorOffsetsCustomOffsetsTopic
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > kafka.api.TransactionsTest.testFailureToFenceEpoch(String).quorum=kraft
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> kafka.security.authorizer.AuthorizerTest.testDeleteAllAclOnWildcardResource(String).quorum=kraft
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > > kafka.server.RaftClusterSnapshotTest.testSnapshotsGenerated()
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> kafka.server.metadata.BrokerMetadataPublisherTest.testReloadUpdatedFilesWithoutConfigChange()
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > kafka.zk.ZkMigrationIntegrationTest.[1]
> > > > > > Type=ZK, Name=testDualWrite, MetadataVersion=3.4-IV0,
> > > > Security=PLAINTEXT
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.streams.integration.AdjustStreamThreadCountTest.shouldAddAndRemoveThreadsMultipleTimes()
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.trogdor.coordinator.CoordinatorTest.testTaskRequestWithOldStartMsGetsUpdated()
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationBaseTest.testRestartReplication()
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationBaseTest.testOneWayReplicationWithFrequentOffsetSyncs()
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationExactlyOnceTest.testReplication()
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationExactlyOnceTest.testReplicationWithEmptyPartition()
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationExactlyOnceTest.testReplicateSourceDefault()
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationExactlyOnceTest.testOffsetSyncsTopicsOnTarget()
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationExactlyOnceTest.testReplicateTargetDefault()
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationExactlyOnceTest.testNoCheckpointsIfNoRecordsAreMirrored()
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationExactlyOnceTest.testOneWayReplicationWithAutoOffsetSync()
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationExactlyOnceTest.testSyncTopicConfigs()
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationExactlyOnceTest.testRestartReplication()
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationExactlyOnceTest.testOneWayReplicationWithFrequentOffsetSyncs()
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationSSLTest.testReplication()
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationSSLTest.testReplicationWithEmptyPartition()
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationSSLTest.testReplicateSourceDefault()
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationSSLTest.testOffsetSyncsTopicsOnTarget()
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationSSLTest.testReplicateTargetDefault()
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationSSLTest.testNoCheckpointsIfNoRecordsAreMirrored()
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.integration.ConnectorClientPolicyIntegrationTest.testCreateWithAllowedOverridesForPrincipalPolicy
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.integration.ConnectorClientPolicyIntegrationTest.testCreateWithOverridesForNonePolicy
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.integration.ConnectorClientPolicyIntegrationTest.testCreateWithAllowedOverridesForDefaultPolicy
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.integration.ConnectorClientPolicyIntegrationTest.testCreateWithNoAllowedOverridesForNonePolicy
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.integration.ConnectorTopicsIntegrationTest.testGetActiveTopics
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.integration.ConnectorTopicsIntegrationTest.testTopicTrackingResetIsDisabled
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.integration.ConnectorTopicsIntegrationTest.testTopicTrackingIsDisabled
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.integration.ExactlyOnceSourceIntegrationTest.testSeparateOffsetsTopic
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.integration.ExampleConnectIntegrationTest.testSinkConnector
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.integration.OffsetsApiIntegrationTest.testGetSinkConnectorOffsets
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.integration.OffsetsApiIntegrationTest.testGetNonExistentConnectorOffsets
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.integration.OffsetsApiIntegrationTest.testGetSinkConnectorOffsetsOverriddenConsumerGroupId
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.integration.OffsetsApiIntegrationTest.testGetSourceConnectorOffsets
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.integration.OffsetsApiIntegrationTest.testGetSinkConnectorOffsetsDifferentKafkaClusterTargeted
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> integration.kafka.server.FetchFromFollowerIntegrationTest.testRackAwareRangeAssignor()
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> kafka.security.authorizer.AuthorizerTest.testSuperUserHasAccess(String).quorum=kraft
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> kafka.security.authorizer.AuthorizerTest.testSingleCharacterResourceAcls(String).quorum=kraft
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> kafka.security.authorizer.AuthorizerTest.testSingleCharacterResourceAcls(String).quorum=kraft
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > > kafka.network.SocketServerTest.testConnectionRateLimit()
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > > kafka.server.RaftClusterSnapshotTest.testSnapshotsGenerated()
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > kafka.zk.ZkMigrationIntegrationTest.[1]
> > > > > > Type=ZK, Name=testDualWrite, MetadataVersion=3.4-IV0,
> > > > Security=PLAINTEXT
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.controller.QuorumControllerTest.testDelayedConfigurationOperations()
> > > > > > Build / JDK 17 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.testReplicationIsCreatingTopicsUsingProvidedForwardingAdmin()
> > > > > > Build / JDK 17 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.testCreatePartitionsUseProvidedForwardingAdmin()
> > > > > > Build / JDK 17 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.testSyncTopicConfigUseProvidedForwardingAdmin()
> > > > > > Build / JDK 17 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.testReplicationIsCreatingTopicsUsingProvidedForwardingAdmin()
> > > > > > Build / JDK 17 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.testCreatePartitionsUseProvidedForwardingAdmin()
> > > > > > Build / JDK 17 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.testSyncTopicConfigUseProvidedForwardingAdmin()
> > > > > > Build / JDK 8 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.testReplicationIsCreatingTopicsUsingProvidedForwardingAdmin()
> > > > > > Build / JDK 8 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.testCreatePartitionsUseProvidedForwardingAdmin()
> > > > > > Build / JDK 8 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.testSyncTopicConfigUseProvidedForwardingAdmin()
> > > > > > Build / JDK 8 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.testReplicationIsCreatingTopicsUsingProvidedForwardingAdmin()
> > > > > > Build / JDK 8 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.testCreatePartitionsUseProvidedForwardingAdmin()
> > > > > > Build / JDK 8 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.testSyncTopicConfigUseProvidedForwardingAdmin()
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.testReplicationIsCreatingTopicsUsingProvidedForwardingAdmin()
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.testCreatePartitionsUseProvidedForwardingAdmin()
> > > > > > Build / JDK 11 and Scala 2.13 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.testSyncTopicConfigUseProvidedForwardingAdmin()
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.testReplicationIsCreatingTopicsUsingProvidedForwardingAdmin()
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.testCreatePartitionsUseProvidedForwardingAdmin()
> > > > > > Build / JDK 11 and Scala 2.12 /
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.testSyncTopicConfigUseProvidedForwardingAdmin()
> > > > > >
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> https://ci-builds.apache.org/job/Kafka/job/kafka/job/trunk/1764/#showFailuresLink
> > > > > >
> > > > > > Ismael
> > > > > >
> > > > >
> > > >
> > >
> >
>

Reply via email to