You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by da...@apache.org on 2025/01/24 14:28:39 UTC
(kafka) branch trunk updated (0c9df75295f -> 8c0a0e07ced)
This is an automated email from the ASF dual-hosted git repository.
davidarthur pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 0c9df75295f KAFKA-18474: Remove zkBroker listener (#18477)
add 8c0a0e07ced KAFKA-17587 Refactor test infrastructure (#18602)
No new revisions were added by this update.
Summary of changes:
.github/scripts/junit.py | 5 +-
build.gradle | 107 +++++++++++----------
checkstyle/import-control-coordinator-common.xml | 1 +
checkstyle/import-control-core.xml | 1 +
checkstyle/import-control-group-coordinator.xml | 1 +
checkstyle/import-control-metadata.xml | 1 +
checkstyle/import-control-server-common.xml | 1 +
checkstyle/import-control-server.xml | 1 +
checkstyle/import-control-share-coordinator.xml | 1 +
checkstyle/import-control-storage.xml | 1 +
...=> import-control-test-common-internal-api.xml} | 21 +++-
....xml => import-control-test-common-runtime.xml} | 8 +-
...api.xml => import-control-test-common-util.xml} | 6 +-
.../import-control-transaction-coordinator.xml | 1 +
checkstyle/import-control.xml | 3 +
.../internals/AbstractCoordinatorTest.java | 8 +-
.../java/kafka/admin/AdminFenceProducersTest.java | 6 +-
.../test/java/kafka/admin/ClientTelemetryTest.java | 6 +-
.../kafka/admin/ConfigCommandIntegrationTest.java | 5 +-
.../src/test/java/kafka/admin/DeleteTopicTest.java | 6 +-
.../admin/UserScramCredentialsCommandTest.java | 6 +-
.../clients/consumer/ConsumerIntegrationTest.java | 6 +-
.../BootstrapControllersIntegrationTest.java | 5 +-
.../kafka/server/LogManagerIntegrationTest.java | 6 +-
.../java/kafka/test/api/ShareConsumerTest.java | 5 +-
.../api/GroupCoordinatorIntegrationTest.scala | 5 +-
.../transaction/ProducerIntegrationTest.scala | 6 +-
.../kafka/server/KRaftClusterTest.scala | 2 +-
.../server/MetadataVersionIntegrationTest.scala | 5 +-
.../kafka/server/RaftClusterSnapshotTest.scala | 3 +-
.../server/AbstractApiVersionsRequestTest.scala | 2 +-
.../server/AllocateProducerIdsRequestTest.scala | 5 +-
.../unit/kafka/server/ApiVersionsRequestTest.scala | 5 +-
.../unit/kafka/server/BrokerMetricNamesTest.scala | 5 +-
.../server/BrokerRegistrationRequestTest.scala | 5 +-
.../kafka/server/ClientQuotasRequestTest.scala | 5 +-
.../server/ConsumerGroupDescribeRequestTest.scala | 5 +-
.../server/ConsumerGroupHeartbeatRequestTest.scala | 5 +-
.../server/ConsumerProtocolMigrationTest.scala | 5 +-
.../unit/kafka/server/ControllerApisTest.scala | 2 +-
.../kafka/server/DeleteGroupsRequestTest.scala | 5 +-
.../kafka/server/DescribeGroupsRequestTest.scala | 5 +-
.../kafka/server/DescribeQuorumRequestTest.scala | 5 +-
.../server/GroupCoordinatorBaseRequestTest.scala | 2 +-
.../unit/kafka/server/HeartbeatRequestTest.scala | 5 +-
.../unit/kafka/server/JoinGroupRequestTest.scala | 5 +-
.../unit/kafka/server/LeaveGroupRequestTest.scala | 5 +-
.../unit/kafka/server/ListGroupsRequestTest.scala | 5 +-
.../kafka/server/OffsetCommitRequestTest.scala | 5 +-
.../kafka/server/OffsetDeleteRequestTest.scala | 5 +-
.../unit/kafka/server/OffsetFetchRequestTest.scala | 6 +-
.../kafka/server/SaslApiVersionsRequestTest.scala | 5 +-
.../server/ShareFetchAcknowledgeRequestTest.scala | 5 +-
.../server/ShareGroupDescribeRequestTest.scala | 5 +-
.../server/ShareGroupHeartbeatRequestTest.scala | 5 +-
.../unit/kafka/server/SyncGroupRequestTest.scala | 5 +-
.../kafka/server/TxnOffsetCommitRequestTest.scala | 5 +-
.../metadata/BrokerMetadataPublisherTest.scala | 2 +-
settings.gradle | 4 +-
.../storage/RemoteLogSegmentLifecycleTest.java | 6 +-
...ogMetadataManagerMultipleSubscriptionsTest.java | 6 +-
...icBasedRemoteLogMetadataManagerRestartTest.java | 6 +-
.../TopicBasedRemoteLogMetadataManagerTest.java | 5 +-
.../storage/RemoteLogMetadataManagerTest.java | 6 +-
.../org/apache/kafka/common/test/api/Type.java | 40 --------
.../apache/kafka/common/test/api/AutoStart.java | 0
.../kafka/common/test/api/ClusterConfig.java | 8 +-
.../common/test/api/ClusterConfigProperty.java | 0
.../kafka/common/test/api/ClusterFeature.java | 0
.../kafka/common/test/api/ClusterGenerator.java | 0
.../kafka/common/test/api/ClusterTemplate.java | 0
.../apache/kafka/common/test/api/ClusterTest.java | 4 +-
.../kafka/common/test/api/ClusterTestDefaults.java | 0
.../apache/kafka/common/test/api/ClusterTests.java | 0
.../kafka/common/test/api/DetectThreadLeak.java | 0
.../org/apache/kafka/common/test/api/README.md | 2 +-
.../kafka/common/test/api/TestKitDefaults.java | 31 +++---
.../org/apache/kafka/common/test/api/Type.java} | 10 +-
.../kafka/common/test/api/ClusterConfigTest.java | 13 +--
.../common/test/api/DetectThreadLeakTest.java | 0
.../src/test}/resources/log4j2.yaml | 0
.../apache/kafka/common/test}/ClusterInstance.java | 7 +-
.../org/apache/kafka/common/test/JaasModule.java | 0
.../org/apache/kafka/common/test/JaasUtils.java | 0
.../kafka/common/test/KafkaClusterTestKit.java | 0
.../common/test/KafkaClusterThreadFactory.java | 0
.../apache/kafka/common/test/MockController.java | 0
.../apache/kafka/common/test/MockFaultHandler.java | 0
.../common/test/PreboundSocketFactoryManager.java | 0
.../org/apache/kafka/common/test/TestKitNode.java | 0
.../org/apache/kafka/common/test/TestKitNodes.java | 20 ++--
.../org/apache/kafka/common/test/TestUtils.java | 0
.../junit}/ClusterInstanceParameterResolver.java | 8 +-
.../common/test/junit}/ClusterTestExtensions.java | 63 +++++++++---
.../test/junit}/RaftClusterInvocationContext.java | 5 +-
.../org.junit.jupiter.api.extension.Extension | 3 +-
.../src/main}/resources/log4j2.yaml | 0
.../kafka/common/test/KafkaClusterTestKitTest.java | 0
.../common/test/KafkaClusterThreadFactoryTest.java | 0
.../apache/kafka/common/test/TestKitNodeTest.java | 0
.../test/junit}/ClusterTestExtensionsTest.java | 15 ++-
.../test/junit}/ClusterTestExtensionsUnitTest.java | 5 +-
.../org/apache/kafka/common/test/api/Flaky.java | 0
.../test/junit/AutoQuarantinedTestFilter.java | 0
.../test/junit/QuarantinedPostDiscoveryFilter.java | 0
...org.junit.platform.launcher.PostDiscoveryFilter | 0
.../src/main/resources/junit-platform.properties | 0
.../test/junit/AutoQuarantinedTestFilterTest.java | 0
.../junit/QuarantinedPostDiscoveryFilterTest.java | 0
.../org/apache/kafka/tools/AclCommandTest.java | 5 +-
.../kafka/tools/BrokerApiVersionsCommandTest.java | 6 +-
.../org/apache/kafka/tools/ClusterToolTest.java | 5 +-
.../kafka/tools/DeleteRecordsCommandTest.java | 5 +-
.../org/apache/kafka/tools/FeatureCommandTest.java | 5 +-
.../org/apache/kafka/tools/GetOffsetShellTest.java | 6 +-
.../org/apache/kafka/tools/GroupsCommandTest.java | 5 +-
.../kafka/tools/LeaderElectionCommandTest.java | 5 +-
.../org/apache/kafka/tools/LogDirsCommandTest.java | 5 +-
.../kafka/tools/MetadataQuorumCommandTest.java | 5 +-
.../org/apache/kafka/tools/TopicCommandTest.java | 5 +-
.../kafka/tools/consumer/ConsoleConsumerTest.java | 5 +-
.../consumer/group/DeleteConsumerGroupsTest.java | 6 +-
...OffsetsConsumerGroupCommandIntegrationTest.java | 5 +-
.../consumer/group/DescribeConsumerGroupTest.java | 5 +-
.../consumer/group/ListConsumerGroupTest.java | 5 +-
.../group/ResetConsumerGroupOffsetTest.java | 6 +-
.../reassign/ReassignPartitionsCommandTest.java | 5 +-
127 files changed, 291 insertions(+), 438 deletions(-)
copy checkstyle/{import-control-test-common.xml => import-control-test-common-internal-api.xml} (59%)
rename checkstyle/{import-control-test-common.xml => import-control-test-common-runtime.xml} (86%)
rename checkstyle/{import-control-test-common-api.xml => import-control-test-common-util.xml} (90%)
delete mode 100644 test-common/test-common-api/src/main/java/org/apache/kafka/common/test/api/Type.java
copy test-common/{test-common-api => test-common-internal-api}/src/main/java/org/apache/kafka/common/test/api/AutoStart.java (100%)
rename test-common/{test-common-api => test-common-internal-api}/src/main/java/org/apache/kafka/common/test/api/ClusterConfig.java (97%)
rename test-common/{test-common-api => test-common-internal-api}/src/main/java/org/apache/kafka/common/test/api/ClusterConfigProperty.java (100%)
rename test-common/{test-common-api => test-common-internal-api}/src/main/java/org/apache/kafka/common/test/api/ClusterFeature.java (100%)
rename test-common/{test-common-api => test-common-internal-api}/src/main/java/org/apache/kafka/common/test/api/ClusterGenerator.java (100%)
rename test-common/{test-common-api => test-common-internal-api}/src/main/java/org/apache/kafka/common/test/api/ClusterTemplate.java (100%)
rename test-common/{test-common-api => test-common-internal-api}/src/main/java/org/apache/kafka/common/test/api/ClusterTest.java (92%)
rename test-common/{test-common-api => test-common-internal-api}/src/main/java/org/apache/kafka/common/test/api/ClusterTestDefaults.java (100%)
rename test-common/{test-common-api => test-common-internal-api}/src/main/java/org/apache/kafka/common/test/api/ClusterTests.java (100%)
rename test-common/{test-common-api => test-common-internal-api}/src/main/java/org/apache/kafka/common/test/api/DetectThreadLeak.java (100%)
rename test-common/{test-common-api => test-common-internal-api}/src/main/java/org/apache/kafka/common/test/api/README.md (98%)
copy clients/src/test/java/org/apache/kafka/common/metrics/internals/MetricsUtilsTest.java => test-common/test-common-internal-api/src/main/java/org/apache/kafka/common/test/api/TestKitDefaults.java (55%)
rename test-common/{test-common-api/src/main/java/org/apache/kafka/common/test/api/AutoStart.java => test-common-internal-api/src/main/java/org/apache/kafka/common/test/api/Type.java} (82%)
rename test-common/{test-common-api => test-common-internal-api}/src/test/java/org/apache/kafka/common/test/api/ClusterConfigTest.java (91%)
rename test-common/{test-common-api => test-common-internal-api}/src/test/java/org/apache/kafka/common/test/api/DetectThreadLeakTest.java (100%)
rename test-common/{src/main => test-common-internal-api/src/test}/resources/log4j2.yaml (100%)
rename test-common/{test-common-api/src/main/java/org/apache/kafka/common/test/api => test-common-runtime/src/main/java/org/apache/kafka/common/test}/ClusterInstance.java (98%)
rename test-common/{ => test-common-runtime}/src/main/java/org/apache/kafka/common/test/JaasModule.java (100%)
rename test-common/{ => test-common-runtime}/src/main/java/org/apache/kafka/common/test/JaasUtils.java (100%)
rename test-common/{ => test-common-runtime}/src/main/java/org/apache/kafka/common/test/KafkaClusterTestKit.java (100%)
rename test-common/{ => test-common-runtime}/src/main/java/org/apache/kafka/common/test/KafkaClusterThreadFactory.java (100%)
rename test-common/{ => test-common-runtime}/src/main/java/org/apache/kafka/common/test/MockController.java (100%)
rename test-common/{ => test-common-runtime}/src/main/java/org/apache/kafka/common/test/MockFaultHandler.java (100%)
rename test-common/{ => test-common-runtime}/src/main/java/org/apache/kafka/common/test/PreboundSocketFactoryManager.java (100%)
rename test-common/{ => test-common-runtime}/src/main/java/org/apache/kafka/common/test/TestKitNode.java (100%)
rename test-common/{ => test-common-runtime}/src/main/java/org/apache/kafka/common/test/TestKitNodes.java (94%)
rename test-common/{ => test-common-runtime}/src/main/java/org/apache/kafka/common/test/TestUtils.java (100%)
rename test-common/{test-common-api/src/main/java/org/apache/kafka/common/test/api => test-common-runtime/src/main/java/org/apache/kafka/common/test/junit}/ClusterInstanceParameterResolver.java (92%)
rename test-common/{test-common-api/src/main/java/org/apache/kafka/common/test/api => test-common-runtime/src/main/java/org/apache/kafka/common/test/junit}/ClusterTestExtensions.java (84%)
rename test-common/{test-common-api/src/main/java/org/apache/kafka/common/test/api => test-common-runtime/src/main/java/org/apache/kafka/common/test/junit}/RaftClusterInvocationContext.java (98%)
copy connect/json/src/test/resources/connect-test.properties => test-common/test-common-runtime/src/main/resources/META-INF/services/org.junit.jupiter.api.extension.Extension (93%)
rename test-common/{test-common-api/src/test => test-common-runtime/src/main}/resources/log4j2.yaml (100%)
rename test-common/{ => test-common-runtime}/src/test/java/org/apache/kafka/common/test/KafkaClusterTestKitTest.java (100%)
rename test-common/{ => test-common-runtime}/src/test/java/org/apache/kafka/common/test/KafkaClusterThreadFactoryTest.java (100%)
rename test-common/{ => test-common-runtime}/src/test/java/org/apache/kafka/common/test/TestKitNodeTest.java (100%)
rename test-common/{test-common-api/src/test/java/org/apache/kafka/common/test/api => test-common-runtime/src/test/java/org/apache/kafka/common/test/junit}/ClusterTestExtensionsTest.java (97%)
rename test-common/{test-common-api/src/test/java/org/apache/kafka/common/test/api => test-common-runtime/src/test/java/org/apache/kafka/common/test/junit}/ClusterTestExtensionsUnitTest.java (95%)
rename test-common/{test-common-api => test-common-util}/src/main/java/org/apache/kafka/common/test/api/Flaky.java (100%)
rename test-common/{test-common-runtime => test-common-util}/src/main/java/org/apache/kafka/common/test/junit/AutoQuarantinedTestFilter.java (100%)
rename test-common/{test-common-runtime => test-common-util}/src/main/java/org/apache/kafka/common/test/junit/QuarantinedPostDiscoveryFilter.java (100%)
rename test-common/{test-common-runtime => test-common-util}/src/main/resources/META-INF/services/org.junit.platform.launcher.PostDiscoveryFilter (100%)
rename test-common/{test-common-runtime => test-common-util}/src/main/resources/junit-platform.properties (100%)
rename test-common/{test-common-runtime => test-common-util}/src/test/java/org/apache/kafka/common/test/junit/AutoQuarantinedTestFilterTest.java (100%)
rename test-common/{test-common-runtime => test-common-util}/src/test/java/org/apache/kafka/common/test/junit/QuarantinedPostDiscoveryFilterTest.java (100%)