This is an automated email from the ASF dual-hosted git repository.
jsancio pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 8d88b20 KAFKA-10199: Add interface for state updater (#11499)
add 711b603 MINOR: Cleanup admin creation logic in integration tests
(#11790)
No new revisions were added by this update.
Summary of changes:
.../server/metadata/BrokerMetadataListener.scala | 4 +-
.../test/junit/ZkClusterInvocationContext.java | 2 +-
.../kafka/admin/BrokerApiVersionsCommandTest.scala | 4 +-
.../kafka/admin/ListOffsetsIntegrationTest.scala | 2 +-
.../admin/ReassignPartitionsIntegrationTest.scala | 5 +-
.../AdminClientWithPoliciesIntegrationTest.scala | 2 +-
.../kafka/api/AuthorizerIntegrationTest.scala | 163 +++++++++---------
.../kafka/api/BaseAdminIntegrationTest.scala | 2 +-
.../kafka/api/BaseProducerSendTest.scala | 30 ++--
.../kafka/api/CustomQuotaCallbackTest.scala | 1 -
.../DelegationTokenEndToEndAuthorizationTest.scala | 2 +-
.../api/DescribeAuthorizedOperationsTest.scala | 2 +-
.../kafka/api/EndToEndAuthorizationTest.scala | 2 +-
.../kafka/api/EndToEndClusterIdTest.scala | 4 +-
.../api/GroupCoordinatorIntegrationTest.scala | 2 +-
.../kafka/api/IntegrationTestHarness.scala | 23 ++-
.../scala/integration/kafka/api/MetricsTest.scala | 2 +-
.../kafka/api/PlaintextAdminIntegrationTest.scala | 7 +-
.../kafka/api/PlaintextConsumerTest.scala | 2 +-
.../kafka/api/PlaintextProducerSendTest.scala | 20 +--
.../kafka/api/ProducerCompressionTest.scala | 2 +-
.../kafka/api/ProducerFailureHandlingTest.scala | 6 +-
.../kafka/api/ProducerSendWhileDeletionTest.scala | 2 +-
.../kafka/api/RackAwareAutoTopicCreationTest.scala | 2 +-
.../SaslClientsWithInvalidCredentialsTest.scala | 6 +-
.../kafka/api/TransactionsExpirationTest.scala | 2 +-
.../integration/kafka/api/TransactionsTest.scala | 4 +-
.../api/TransactionsWithMaxInFlightOneTest.scala | 2 +-
.../FetchRequestBetweenDifferentIbpTest.scala | 6 +-
.../kafka/server/FetchRequestTestDowngrade.scala | 2 +-
.../MetadataRequestBetweenDifferentIbpTest.scala | 2 +-
.../kafka/tools/MirrorMakerIntegrationTest.scala | 9 +-
.../scala/kafka/tools/GetOffsetShellTest.scala | 4 +-
.../other/kafka/ReplicationQuotasTestRig.scala | 7 +-
.../scala/unit/kafka/admin/AddPartitionsTest.scala | 8 +-
.../kafka/admin/ConsumerGroupCommandTest.scala | 6 +-
.../kafka/admin/DelegationTokenCommandTest.scala | 10 +-
.../kafka/admin/DeleteConsumerGroupsTest.scala | 22 +--
...ffsetsConsumerGroupCommandIntegrationTest.scala | 6 +-
.../scala/unit/kafka/admin/DeleteTopicTest.scala | 4 +-
.../kafka/admin/DescribeConsumerGroupTest.scala | 64 +++----
.../unit/kafka/admin/FeatureCommandTest.scala | 10 +-
.../kafka/admin/LeaderElectionCommandTest.scala | 3 +-
.../unit/kafka/admin/ListConsumerGroupTest.scala | 12 +-
.../unit/kafka/admin/LogDirsCommandTest.scala | 8 +-
.../kafka/admin/ResetConsumerGroupOffsetTest.scala | 4 +-
.../kafka/admin/TopicCommandIntegrationTest.scala | 2 +-
.../admin/UserScramCredentialsCommandTest.scala | 2 +-
.../kafka/integration/KafkaServerTestHarness.scala | 92 +++++++---
.../integration/UncleanLeaderElectionTest.scala | 6 +-
.../unit/kafka/server/BaseFetchRequestTest.scala | 2 +-
.../DelegationTokenRequestsOnPlainTextTest.scala | 2 +-
.../kafka/server/DelegationTokenRequestsTest.scala | 2 +-
...nTokenRequestsWithDisableTokenFeatureTest.scala | 2 +-
.../kafka/server/DynamicConfigChangeTest.scala | 2 +-
.../FetchRequestDownConversionConfigTest.scala | 2 +-
.../kafka/server/FetchRequestMaxBytesTest.scala | 2 +-
.../scala/unit/kafka/server/FetchRequestTest.scala | 17 +-
.../scala/unit/kafka/server/LogRecoveryTest.scala | 4 +-
.../unit/kafka/server/MetadataRequestTest.scala | 6 +-
.../scala/unit/kafka/server/ReplicaFetchTest.scala | 2 +-
.../unit/kafka/server/ReplicationQuotasTest.scala | 4 +-
.../unit/kafka/server/ServerShutdownTest.scala | 14 +-
.../TopicIdWithOldInterBrokerProtocolTest.scala | 6 +-
...chDrivenReplicationProtocolAcceptanceTest.scala | 14 +-
.../server/epoch/LeaderEpochIntegrationTest.scala | 6 +-
.../test/scala/unit/kafka/utils/TestUtils.scala | 187 ++++++++-------------
.../TopicBasedRemoteLogMetadataManagerHarness.java | 2 +-
...icBasedRemoteLogMetadataManagerRestartTest.java | 8 +-
.../TopicBasedRemoteLogMetadataManagerTest.java | 8 +-
70 files changed, 442 insertions(+), 446 deletions(-)
