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 >
