[kafka] branch trunk updated (5cf5cc2 -> ac89e49)

[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 5cf5cc2  KAFKA-10401; Ensure `currentStateTimeStamp` is set correctly by group coordinator (#9202)
     add ac89e49  MINOR: Use `Map.forKeyValue` to avoid tuple allocation in Scala 2.13 (#9299)

No new revisions were added by this update.

Summary of changes:
 .../kafka/admin/BrokerApiVersionsCommand.scala     |  3 +-
 .../src/main/scala/kafka/admin/ConfigCommand.scala |  2 +-
 .../scala/kafka/admin/ConsumerGroupCommand.scala   |  3 +-
 .../scala/kafka/admin/LeaderElectionCommand.scala  |  3 +-
 .../PreferredReplicaLeaderElectionCommand.scala    |  5 ++-
 .../kafka/admin/ReassignPartitionsCommand.scala    |  3 +-
 .../scala/kafka/admin/ZkSecurityMigrator.scala     |  3 +-
 .../controller/ControllerChannelManager.scala      | 13 ++++---
 .../scala/kafka/controller/ControllerContext.scala |  3 +-
 .../scala/kafka/controller/KafkaController.scala   | 11 +++---
 .../kafka/controller/PartitionStateMachine.scala   |  5 ++-
 .../kafka/controller/ReplicaStateMachine.scala     |  5 ++-
 .../kafka/coordinator/group/GroupMetadata.scala    |  7 ++--
 .../coordinator/group/GroupMetadataManager.scala   | 13 ++++---
 .../TransactionMarkerChannelManager.scala          |  3 +-
 .../transaction/TransactionStateManager.scala      |  3 +-
 .../main/scala/kafka/network/RequestChannel.scala  |  3 +-
 .../main/scala/kafka/network/SocketServer.scala    |  3 +-
 .../kafka/security/authorizer/AclAuthorizer.scala  | 45 +++++++++++-----------
 .../kafka/server/AbstractFetcherManager.scala      |  3 +-
 .../scala/kafka/server/AbstractFetcherThread.scala |  7 ++--
 .../src/main/scala/kafka/server/AdminManager.scala |  5 ++-
 .../main/scala/kafka/server/ConfigHandler.scala    |  3 +-
 .../scala/kafka/server/DelayedDeleteRecords.scala  |  7 ++--
 .../main/scala/kafka/server/DelayedProduce.scala   |  7 ++--
 .../scala/kafka/server/DynamicBrokerConfig.scala   | 13 ++++---
 core/src/main/scala/kafka/server/KafkaApis.scala   | 33 ++++++++--------
 .../main/scala/kafka/server/MetadataCache.scala    |  3 +-
 .../scala/kafka/server/ReplicaFetcherThread.scala  |  3 +-
 .../main/scala/kafka/server/ReplicaManager.scala   | 13 ++++---
 .../main/scala/kafka/tools/ConsoleConsumer.scala   |  6 +--
 .../main/scala/kafka/tools/DumpLogSegments.scala   |  5 ++-
 .../main/scala/kafka/tools/GetOffsetShell.scala    |  2 +-
 core/src/main/scala/kafka/utils/Implicits.scala    | 18 +++++++++
 core/src/main/scala/kafka/zk/AdminZkClient.scala   |  3 +-
 .../kafka/api/TransactionsBounceTest.scala         |  2 +-
 gradle/dependencies.gradle                         |  2 +-
 gradle/spotbugs-exclude.xml                        |  6 +++
 38 files changed, 166 insertions(+), 111 deletions(-)