This is an automated email from the ASF dual-hosted git repository.
chia7712 pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 7bd10ff MINOR: Make data in FetchSnapshotRequest and
FetchSnapshotRespponse private (#9820)
add 5a4bbb9 KAFKA-7341 Migrate core module to JUnit 5 (#9855)
No new revisions were added by this update.
Summary of changes:
build.gradle | 8 +-
.../kafka/clients/producer/KafkaProducerTest.java | 8 +
.../kafka/admin/BrokerApiVersionsCommandTest.scala | 10 +-
.../admin/ReassignPartitionsIntegrationTest.scala | 39 +-
.../kafka/api/AbstractConsumerTest.scala | 10 +-
.../AdminClientWithPoliciesIntegrationTest.scala | 26 +-
.../kafka/api/AuthorizerIntegrationTest.scala | 43 +-
.../kafka/api/BaseAdminIntegrationTest.scala | 16 +-
.../integration/kafka/api/BaseConsumerTest.scala | 4 +-
.../kafka/api/BaseProducerSendTest.scala | 65 +--
.../integration/kafka/api/BaseQuotaTest.scala | 45 +-
.../integration/kafka/api/ClientIdQuotaTest.scala | 4 +-
.../integration/kafka/api/ConsumerBounceTest.scala | 22 +-
.../kafka/api/ConsumerTopicCreationTest.scala | 118 ++---
.../kafka/api/CustomQuotaCallbackTest.scala | 12 +-
.../DelegationTokenEndToEndAuthorizationTest.scala | 7 +-
.../api/DescribeAuthorizedOperationsTest.scala | 8 +-
.../kafka/api/EndToEndAuthorizationTest.scala | 58 +--
.../kafka/api/EndToEndClusterIdTest.scala | 7 +-
.../kafka/api/GroupAuthorizerIntegrationTest.scala | 7 +-
.../api/GroupCoordinatorIntegrationTest.scala | 6 +-
.../kafka/api/IntegrationTestHarness.scala | 6 +-
.../integration/kafka/api/LogAppendTimeTest.scala | 7 +-
.../scala/integration/kafka/api/MetricsTest.scala | 38 +-
.../kafka/api/PlaintextAdminIntegrationTest.scala | 260 ++++------
.../kafka/api/PlaintextConsumerTest.scala | 79 ++-
.../api/PlaintextEndToEndAuthorizationTest.scala | 6 +-
.../kafka/api/PlaintextProducerSendTest.scala | 8 +-
.../kafka/api/ProducerCompressionTest.scala | 47 +-
.../kafka/api/ProducerFailureHandlingTest.scala | 61 +--
.../kafka/api/RackAwareAutoTopicCreationTest.scala | 6 +-
.../SaslClientsWithInvalidCredentialsTest.scala | 29 +-
.../kafka/api/SaslEndToEndAuthorizationTest.scala | 9 +-
.../kafka/api/SaslMultiMechanismConsumerTest.scala | 6 +-
.../kafka/api/SaslPlainPlaintextConsumerTest.scala | 6 +-
.../SaslPlainSslEndToEndAuthorizationTest.scala | 2 +-
.../kafka/api/SaslPlaintextConsumerTest.scala | 6 +-
.../SaslScramSslEndToEndAuthorizationTest.scala | 4 +-
.../kafka/api/SaslSslAdminIntegrationTest.scala | 25 +-
.../kafka/api/SaslSslConsumerTest.scala | 6 +-
.../kafka/api/SslAdminIntegrationTest.scala | 20 +-
.../kafka/api/SslEndToEndAuthorizationTest.scala | 4 +-
.../kafka/api/TransactionsBounceTest.scala | 8 +-
.../kafka/api/TransactionsExpirationTest.scala | 6 +-
.../integration/kafka/api/TransactionsTest.scala | 34 +-
.../api/TransactionsWithMaxInFlightOneTest.scala | 8 +-
.../kafka/api/UserClientIdQuotaTest.scala | 4 +-
.../integration/kafka/api/UserQuotaTest.scala | 6 +-
.../kafka/network/DynamicConnectionQuotaTest.scala | 12 +-
.../kafka/server/DelayedFetchTest.scala | 4 +-
.../server/DynamicBrokerReconfigurationTest.scala | 118 ++---
.../kafka/server/GssapiAuthenticationTest.scala | 25 +-
...ListenersWithSameSecurityProtocolBaseTest.scala | 14 +-
.../kafka/server/ScramServerStartupTest.scala | 6 +-
.../kafka/tools/MirrorMakerIntegrationTest.scala | 14 +-
.../kafka/common/InterBrokerSendThreadTest.scala | 13 +-
.../metrics/LinuxIoMetricsCollectorTest.scala | 9 +-
.../scala/kafka/security/auth/ResourceTest.scala | 4 +-
.../scala/kafka/security/minikdc/MiniKdcTest.scala | 6 +-
.../server/BrokerMetadataCheckpointTest.scala | 4 +-
.../BrokerToControllerRequestThreadTest.scala | 4 +-
.../scala/kafka/tools/CustomDeserializerTest.scala | 9 +-
.../kafka/tools/DefaultMessageFormatterTest.scala | 61 ++-
.../kafka/tools/ReplicaVerificationToolTest.scala | 8 +-
core/src/test/scala/kafka/utils/ExitTest.scala | 4 +-
core/src/test/scala/kafka/utils/LoggingTest.scala | 6 +-
.../test/scala/kafka/utils/ToolsUtilsTest.scala | 4 +-
.../test/scala/kafka/zk/ExtendedAclStoreTest.scala | 4 +-
.../src/test/scala/kafka/zk/FeatureZNodeTest.scala | 39 +-
.../test/scala/kafka/zk/LiteralAclStoreTest.scala | 4 +-
.../test/scala/unit/kafka/KafkaConfigTest.scala | 8 +-
.../scala/unit/kafka/admin/AclCommandTest.scala | 22 +-
.../scala/unit/kafka/admin/AddPartitionsTest.scala | 33 +-
.../unit/kafka/admin/AdminRackAwareTest.scala | 4 +-
.../scala/unit/kafka/admin/ConfigCommandTest.scala | 70 +--
.../kafka/admin/ConsumerGroupCommandTest.scala | 6 +-
.../kafka/admin/DelegationTokenCommandTest.scala | 8 +-
.../kafka/admin/DeleteConsumerGroupsTest.scala | 48 +-
...ffsetsConsumerGroupCommandIntegrationTest.scala | 4 +-
.../scala/unit/kafka/admin/DeleteTopicTest.scala | 56 +--
.../kafka/admin/DescribeConsumerGroupTest.scala | 82 ++-
.../unit/kafka/admin/FeatureCommandTest.scala | 4 +-
.../kafka/admin/LeaderElectionCommandTest.scala | 142 +++---
.../unit/kafka/admin/ListConsumerGroupTest.scala | 4 +-
...PreferredReplicaLeaderElectionCommandTest.scala | 27 +-
.../scala/unit/kafka/admin/RackAwareTest.scala | 15 +-
.../admin/ReassignPartitionsCommandArgsTest.scala | 21 +-
.../kafka/admin/ReassignPartitionsUnitTest.scala | 95 ++--
.../kafka/admin/ResetConsumerGroupOffsetTest.scala | 4 +-
.../scala/unit/kafka/admin/TopicCommandTest.scala | 4 +-
.../admin/TopicCommandWithAdminClientTest.scala | 34 +-
.../kafka/admin/TopicCommandWithZKClientTest.scala | 47 +-
.../admin/UserScramCredentialsCommandTest.scala | 10 +-
.../test/scala/unit/kafka/api/ApiUtilsTest.scala | 20 +-
.../test/scala/unit/kafka/api/ApiVersionTest.scala | 4 +-
.../unit/kafka/cluster/AbstractPartitionTest.scala | 6 +-
.../unit/kafka/cluster/AssignmentStateTest.scala | 61 ++-
.../unit/kafka/cluster/BrokerEndPointTest.scala | 4 +-
.../unit/kafka/cluster/PartitionLockTest.scala | 18 +-
.../scala/unit/kafka/cluster/PartitionTest.scala | 155 +++---
.../scala/unit/kafka/cluster/ReplicaTest.scala | 8 +-
.../ZkNodeChangeNotificationListenerTest.scala | 6 +-
.../controller/ControllerChannelManagerTest.scala | 18 +-
.../kafka/controller/ControllerContextTest.scala | 10 +-
.../controller/ControllerEventManagerTest.scala | 8 +-
.../kafka/controller/ControllerFailoverTest.scala | 10 +-
.../controller/ControllerIntegrationTest.scala | 24 +-
.../PartitionLeaderElectionAlgorithmsTest.scala | 6 +-
.../controller/PartitionStateMachineTest.scala | 21 +-
.../kafka/controller/ReplicaStateMachineTest.scala | 6 +-
.../controller/TopicDeletionManagerTest.scala | 4 +-
.../AbstractCoordinatorConcurrencyTest.scala | 6 +-
.../group/GroupCoordinatorConcurrencyTest.scala | 8 +-
.../coordinator/group/GroupCoordinatorTest.scala | 16 +-
.../group/GroupMetadataManagerTest.scala | 18 +-
.../coordinator/group/GroupMetadataTest.scala | 13 +-
.../coordinator/group/MemberMetadataTest.scala | 4 +-
.../transaction/ProducerIdManagerTest.scala | 6 +-
.../TransactionCoordinatorConcurrencyTest.scala | 14 +-
.../transaction/TransactionCoordinatorTest.scala | 4 +-
.../transaction/TransactionLogTest.scala | 4 +-
.../TransactionMarkerChannelManagerTest.scala | 8 +-
...sactionMarkerRequestCompletionHandlerTest.scala | 22 +-
.../transaction/TransactionMetadataTest.scala | 4 +-
.../transaction/TransactionStateManagerTest.scala | 10 +-
.../kafka/integration/KafkaServerTestHarness.scala | 6 +-
.../MetricsDuringTopicCreationDeletionTest.scala | 4 +-
.../unit/kafka/integration/MinIsrConfigTest.scala | 2 +-
.../integration/UncleanLeaderElectionTest.scala | 30 +-
.../log/AbstractLogCleanerIntegrationTest.scala | 12 +-
.../unit/kafka/log/BrokerCompressionTest.scala | 35 +-
.../unit/kafka/log/LogCleanerIntegrationTest.scala | 27 +-
.../kafka/log/LogCleanerLagIntegrationTest.scala | 38 +-
.../unit/kafka/log/LogCleanerManagerTest.scala | 50 +-
.../LogCleanerParameterizedIntegrationTest.scala | 89 ++--
.../test/scala/unit/kafka/log/LogCleanerTest.scala | 106 ++--
.../scala/unit/kafka/log/LogConcurrencyTest.scala | 16 +-
.../test/scala/unit/kafka/log/LogConfigTest.scala | 16 +-
.../test/scala/unit/kafka/log/LogManagerTest.scala | 72 ++-
.../test/scala/unit/kafka/log/LogSegmentTest.scala | 24 +-
core/src/test/scala/unit/kafka/log/LogTest.scala | 555 +++++++++------------
.../scala/unit/kafka/log/LogValidatorTest.scala | 108 ++--
.../scala/unit/kafka/log/OffsetIndexTest.scala | 54 +-
.../test/scala/unit/kafka/log/OffsetMapTest.scala | 4 +-
.../unit/kafka/log/ProducerStateManagerTest.scala | 29 +-
.../test/scala/unit/kafka/log/TimeIndexTest.scala | 8 +-
.../unit/kafka/log/TransactionIndexTest.scala | 8 +-
.../scala/unit/kafka/metrics/KafkaTimerTest.scala | 4 +-
.../scala/unit/kafka/metrics/MetricsTest.scala | 19 +-
.../unit/kafka/network/ConnectionQuotasTest.scala | 178 +++----
.../unit/kafka/network/RequestChannelTest.scala | 8 +-
.../kafka/network/RequestConvertToJsonTest.scala | 8 +-
.../unit/kafka/network/SocketServerTest.scala | 53 +-
.../unit/kafka/raft/KafkaNetworkChannelTest.scala | 6 +-
.../scala/unit/kafka/raft/RaftManagerTest.scala | 2 +-
.../unit/kafka/security/auth/OperationTest.scala | 4 +-
.../kafka/security/auth/PermissionTypeTest.scala | 11 +-
.../kafka/security/auth/ResourceTypeTest.scala | 12 +-
.../security/auth/SimpleAclAuthorizerTest.scala | 88 ++--
.../kafka/security/auth/ZkAuthorizationTest.scala | 35 +-
.../security/authorizer/AclAuthorizerTest.scala | 102 ++--
.../authorizer/AclAuthorizerWithZkSaslTest.scala | 8 +-
.../kafka/security/authorizer/AclEntryTest.scala | 7 +-
.../AuthorizerInterfaceDefaultTest.scala | 6 +-
.../authorizer/AuthorizerWrapperTest.scala | 30 +-
.../security/authorizer/BaseAuthorizerTest.scala | 172 +++----
.../delegation/DelegationTokenManagerTest.scala | 8 +-
.../server/AbstractApiVersionsRequestTest.scala | 14 +-
.../server/AbstractCreateTopicsRequestTest.scala | 31 +-
.../kafka/server/AbstractFetcherManagerTest.scala | 6 +-
.../kafka/server/AbstractFetcherThreadTest.scala | 10 +-
.../AddPartitionsToTxnRequestServerTest.scala | 6 +-
.../unit/kafka/server/AdvertiseBrokerTest.scala | 6 +-
.../unit/kafka/server/AlterIsrManagerTest.scala | 8 +-
.../server/AlterReplicaLogDirsRequestTest.scala | 4 +-
...rScramCredentialsRequestNotAuthorizedTest.scala | 79 +++
.../AlterUserScramCredentialsRequestTest.scala | 78 +--
.../unit/kafka/server/ApiVersionsRequestTest.scala | 4 +-
.../scala/unit/kafka/server/AuthHelperTest.scala | 4 +-
.../kafka/server/BaseClientQuotaManagerTest.scala | 4 +-
.../kafka/server/BrokerEpochIntegrationTest.scala | 10 +-
.../unit/kafka/server/BrokerFeaturesTest.scala | 4 +-
.../unit/kafka/server/ClientQuotaManagerTest.scala | 52 +-
.../kafka/server/ClientQuotasRequestTest.scala | 12 +-
.../server/ClientRequestQuotaManagerTest.scala | 14 +-
.../ControllerMutationQuotaManagerTest.scala | 17 +-
.../kafka/server/ControllerMutationQuotaTest.scala | 16 +-
.../kafka/server/CreateTopicsRequestTest.scala | 4 +-
.../CreateTopicsRequestWithForwardingTest.scala | 4 +-
.../server/CreateTopicsRequestWithPolicyTest.scala | 2 +-
.../unit/kafka/server/DelayedOperationTest.scala | 84 ++--
.../DelegationTokenRequestsOnPlainTextTest.scala | 8 +-
.../kafka/server/DelegationTokenRequestsTest.scala | 10 +-
...nTokenRequestsWithDisableTokenFeatureTest.scala | 17 +-
.../kafka/server/DeleteTopicsRequestTest.scala | 12 +-
...leteTopicsRequestWithDeletionDisabledTest.scala | 4 +-
.../kafka/server/DescribeLogDirsRequestTest.scala | 6 +-
...rScramCredentialsRequestNotAuthorizedTest.scala | 51 ++
.../DescribeUserScramCredentialsRequestTest.scala | 49 +-
.../kafka/server/DynamicBrokerConfigTest.scala | 40 +-
.../kafka/server/DynamicConfigChangeTest.scala | 75 +--
.../unit/kafka/server/DynamicConfigTest.scala | 4 +-
.../unit/kafka/server/EdgeCaseRequestTest.scala | 14 +-
.../FetchRequestDownConversionConfigTest.scala | 7 +-
.../kafka/server/FetchRequestMaxBytesTest.scala | 14 +-
.../scala/unit/kafka/server/FetchRequestTest.scala | 22 +-
.../scala/unit/kafka/server/FetchSessionTest.scala | 25 +-
.../kafka/server/FinalizedFeatureCacheTest.scala | 12 +-
.../FinalizedFeatureChangeListenerTest.scala | 12 +-
.../unit/kafka/server/ForwardingManagerTest.scala | 4 +-
.../server/HighwatermarkPersistenceTest.scala | 6 +-
.../unit/kafka/server/IsrExpirationTest.scala | 34 +-
.../scala/unit/kafka/server/KafkaApisTest.scala | 8 +-
.../scala/unit/kafka/server/KafkaConfigTest.scala | 12 +-
.../server/KafkaMetricReporterClusterIdTest.scala | 8 +-
.../KafkaMetricReporterExceptionHandlingTest.scala | 9 +-
.../kafka/server/KafkaMetricsReporterTest.scala | 10 +-
.../scala/unit/kafka/server/KafkaServerTest.scala | 7 +-
.../unit/kafka/server/LeaderElectionTest.scala | 26 +-
.../unit/kafka/server/ListOffsetsRequestTest.scala | 4 +-
.../unit/kafka/server/LogDirFailureTest.scala | 23 +-
.../scala/unit/kafka/server/LogOffsetTest.scala | 4 +-
.../scala/unit/kafka/server/LogRecoveryTest.scala | 20 +-
.../unit/kafka/server/MetadataCacheTest.scala | 6 +-
.../unit/kafka/server/MetadataRequestTest.scala | 57 ++-
.../server/OffsetsForLeaderEpochRequestTest.scala | 4 +-
.../unit/kafka/server/ProduceRequestTest.scala | 4 +-
.../server/ReplicaAlterLogDirsThreadTest.scala | 23 +-
.../scala/unit/kafka/server/ReplicaFetchTest.scala | 6 +-
.../kafka/server/ReplicaFetcherThreadTest.scala | 80 ++-
.../kafka/server/ReplicaManagerQuotasTest.scala | 42 +-
.../unit/kafka/server/ReplicaManagerTest.scala | 26 +-
.../kafka/server/ReplicationQuotaManagerTest.scala | 6 +-
.../unit/kafka/server/ReplicationQuotasTest.scala | 24 +-
.../scala/unit/kafka/server/RequestQuotaTest.scala | 48 +-
.../kafka/server/SaslApiVersionsRequestTest.scala | 8 +-
.../kafka/server/ServerGenerateBrokerIdTest.scala | 8 +-
.../kafka/server/ServerGenerateClusterIdTest.scala | 8 +-
.../unit/kafka/server/ServerMetricsTest.scala | 12 +-
.../unit/kafka/server/ServerShutdownTest.scala | 8 +-
.../unit/kafka/server/ServerStartupTest.scala | 21 +-
.../unit/kafka/server/StopReplicaRequestTest.scala | 4 +-
.../server/ThrottledChannelExpirationTest.scala | 27 +-
.../unit/kafka/server/UpdateFeaturesTest.scala | 10 +-
.../unit/kafka/server/ZkAdminManagerTest.scala | 20 +-
.../LeaderEpochCheckpointFileTest.scala | 4 +-
.../checkpoints/OffsetCheckpointFileTest.scala | 7 +-
...chDrivenReplicationProtocolAcceptanceTest.scala | 18 +-
.../server/epoch/LeaderEpochFileCacheTest.scala | 12 +-
.../server/epoch/LeaderEpochIntegrationTest.scala | 6 +-
.../server/epoch/OffsetsForLeaderEpochTest.scala | 8 +-
.../unit/kafka/tools/ConsoleConsumerTest.scala | 35 +-
.../unit/kafka/tools/ConsoleProducerTest.scala | 4 +-
.../unit/kafka/tools/ConsumerPerformanceTest.scala | 4 +-
.../unit/kafka/tools/DumpLogSegmentsTest.scala | 18 +-
.../scala/unit/kafka/tools/MirrorMakerTest.scala | 4 +-
.../unit/kafka/utils/CommandLineUtilsTest.scala | 20 +-
.../scala/unit/kafka/utils/CoreUtilsTest.scala | 12 +-
.../src/test/scala/unit/kafka/utils/JsonTest.scala | 4 +-
.../unit/kafka/utils/PasswordEncoderTest.scala | 10 +-
.../src/test/scala/unit/kafka/utils/PoolTest.scala | 4 +-
.../scala/unit/kafka/utils/QuotaUtilsTest.scala | 11 +-
.../unit/kafka/utils/ReplicationUtilsTest.scala | 6 +-
.../scala/unit/kafka/utils/SchedulerTest.scala | 44 +-
.../unit/kafka/utils/ShutdownableThreadTest.scala | 8 +-
.../test/scala/unit/kafka/utils/TestUtils.scala | 87 +---
.../scala/unit/kafka/utils/ThrottlerTest.scala | 5 +-
.../scala/unit/kafka/utils/TopicFilterTest.scala | 4 +-
.../unit/kafka/utils/json/JsonValueTest.scala | 4 +-
.../unit/kafka/utils/timer/TimerTaskListTest.scala | 4 +-
.../scala/unit/kafka/utils/timer/TimerTest.scala | 14 +-
.../scala/unit/kafka/zk/AdminZkClientTest.scala | 46 +-
.../scala/unit/kafka/zk/KafkaZkClientTest.scala | 123 +++--
.../kafka/zk/ReassignPartitionsZNodeTest.scala | 4 +-
.../scala/unit/kafka/zk/ZooKeeperTestHarness.scala | 24 +-
.../unit/kafka/zookeeper/ZooKeeperClientTest.scala | 167 +++----
276 files changed, 3250 insertions(+), 3877 deletions(-)
create mode 100644
core/src/test/scala/unit/kafka/server/AlterUserScramCredentialsRequestNotAuthorizedTest.scala
create mode 100644
core/src/test/scala/unit/kafka/server/DescribeUserScramCredentialsRequestNotAuthorizedTest.scala
