[kafka] branch trunk updated (9c9a79b -> 7f90a58)

[ij...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

ijuma pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from 9c9a79b  KAFKA-9076: support consumer sync across clusters in MM 2.0 (#7577)
     add 7f90a58  MINOR: Update Scala to 2.13.3 (#8931)

No new revisions were added by this update.

Summary of changes:
 bin/kafka-run-class.sh                             |   2 +-
 bin/windows/kafka-run-class.bat                    |   2 +-
 build.gradle                                       |   2 +-
 core/src/main/scala/kafka/Kafka.scala              |   2 +-
 .../src/main/scala/kafka/admin/ConfigCommand.scala |   6 +-
 .../scala/kafka/admin/ConsumerGroupCommand.scala   |   3 +
 .../PreferredReplicaLeaderElectionCommand.scala    |   4 +-
 .../kafka/admin/ReassignPartitionsCommand.scala    |   2 +-
 .../scala/kafka/admin/ZkSecurityMigrator.scala     |  12 +-
 .../common/ZkNodeChangeNotificationListener.scala  |   8 +-
 .../scala/kafka/controller/ControllerContext.scala |  18 +-
 .../scala/kafka/controller/KafkaController.scala   |  10 +-
 .../coordinator/group/GroupMetadataManager.scala   |   4 +-
 core/src/main/scala/kafka/log/Log.scala            |   4 +-
 core/src/main/scala/kafka/log/LogManager.scala     |   6 +-
 .../kafka/security/authorizer/AclAuthorizer.scala  |  12 +-
 .../scala/kafka/server/AbstractFetcherThread.scala |   2 +-
 .../kafka/server/DelegationTokenManager.scala      |  18 +-
 core/src/main/scala/kafka/server/KafkaApis.scala   |   2 +-
 core/src/main/scala/kafka/server/KafkaConfig.scala |   2 +-
 core/src/main/scala/kafka/server/KafkaServer.scala |   4 +-
 .../src/main/scala/kafka/server/QuotaFactory.scala |   6 +-
 .../kafka/server/ReplicationQuotaManager.scala     |   4 +-
 .../kafka/server/epoch/LeaderEpochFileCache.scala  |   4 +-
 .../kafka/tools/ReplicaVerificationTool.scala      |   4 +-
 .../scala/kafka/tools/StateChangeLogMerger.scala   |   4 +-
 .../main/scala/kafka/utils/json/DecodeJson.scala   |   2 +-
 core/src/main/scala/kafka/utils/timer/Timer.scala  |   2 +-
 .../main/scala/kafka/utils/timer/TimerTask.scala   |   4 +-
 .../scala/kafka/utils/timer/TimerTaskList.scala    |   4 +-
 core/src/main/scala/kafka/zk/KafkaZkClient.scala   |  60 +++---
 .../ZooKeeperMainWithTlsSupportForKafka.scala      |   4 +-
 .../kafka/admin/BrokerApiVersionsCommandTest.scala |   6 +-
 .../AdminClientWithPoliciesIntegrationTest.scala   |   2 +-
 .../kafka/api/BaseAdminIntegrationTest.scala       |   9 +-
 .../kafka/api/PlaintextAdminIntegrationTest.scala  |  54 ++---
 .../SaslClientsWithInvalidCredentialsTest.scala    |   4 +-
 .../kafka/api/SaslEndToEndAuthorizationTest.scala  |   2 +-
 .../kafka/api/SaslSslAdminIntegrationTest.scala    |  18 +-
 .../kafka/api/SslAdminIntegrationTest.scala        |   4 +-
 .../scala/kafka/security/minikdc/MiniKdc.scala     |   2 +-
 core/src/test/scala/kafka/utils/ExitTest.scala     |   4 +-
 .../other/kafka/ReplicationQuotasTestRig.scala     |   4 +-
 .../kafka/admin/DelegationTokenCommandTest.scala   |   2 +-
 .../scala/unit/kafka/admin/DeleteTopicTest.scala   |  18 +-
 ...PreferredReplicaLeaderElectionCommandTest.scala |   2 +-
 .../controller/ControllerIntegrationTest.scala     |  10 +-
 .../group/GroupCoordinatorConcurrencyTest.scala    |   2 +-
 .../coordinator/group/GroupCoordinatorTest.scala   |  10 +-
 .../MetricsDuringTopicCreationDeletionTest.scala   |   2 +-
 .../unit/kafka/integration/MinIsrConfigTest.scala  |   2 +-
 .../integration/UncleanLeaderElectionTest.scala    |  12 +-
 .../test/scala/unit/kafka/log/LogCleanerTest.scala |   2 +-
 .../security/auth/SimpleAclAuthorizerTest.scala    |   2 +-
 .../security/authorizer/AclAuthorizerTest.scala    |   5 +-
 .../delegation/DelegationTokenManagerTest.scala    |  18 +-
 .../DelegationTokenRequestsOnPlainTextTest.scala   |   2 +-
 .../kafka/server/DelegationTokenRequestsTest.scala |   2 +-
 ...nTokenRequestsWithDisableTokenFeatureTest.scala |   2 +-
 .../kafka/server/DynamicConfigChangeTest.scala     |   4 +-
 .../scala/unit/kafka/server/FetchSessionTest.scala |   2 +-
 .../FinalizedFeatureChangeListenerTest.scala       |   2 +-
 .../server/HighwatermarkPersistenceTest.scala      |   6 +-
 .../scala/unit/kafka/server/KafkaConfigTest.scala  | 232 ++++++++++-----------
 .../scala/unit/kafka/server/LogRecoveryTest.scala  |  34 +--
 .../server/ReplicaAlterLogDirsThreadTest.scala     |  14 +-
 .../scala/unit/kafka/server/ReplicaFetchTest.scala |   4 +-
 .../unit/kafka/server/ReplicationQuotasTest.scala  |   2 +-
 .../unit/kafka/server/ServerShutdownTest.scala     |   6 +-
 ...chDrivenReplicationProtocolAcceptanceTest.scala |  12 +-
 .../server/epoch/LeaderEpochIntegrationTest.scala  |   4 +-
 .../unit/kafka/tools/DumpLogSegmentsTest.scala     |   2 +-
 .../scala/unit/kafka/utils/MockScheduler.scala     |   2 +-
 .../test/scala/unit/kafka/utils/TestUtils.scala    |  14 +-
 .../scala/unit/kafka/zk/AdminZkClientTest.scala    |   2 +-
 .../scala/unit/kafka/zk/KafkaZkClientTest.scala    |   8 +-
 gradle.properties                                  |   2 +-
 gradle/dependencies.gradle                         |   2 +-
 .../kafka/streams/scala/kstream/KTableTest.scala   |   8 +-
 79 files changed, 382 insertions(+), 405 deletions(-)