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 5583089  KAFKA-9942: ConfigCommand fails to set client quotas for default users with --bootstrap-server. (#8628)
     add 847ff8f  MINOR: Use `forEach` and `ifPresent` to simplify Scala code (#8642)

No new revisions were added by this update.

Summary of changes:
 .../clients/consumer/internals/FetcherTest.java    |  4 +-
 core/src/main/scala/kafka/admin/AclCommand.scala   | 17 +++--
 .../kafka/admin/BrokerApiVersionsCommand.scala     |  2 +-
 .../scala/kafka/admin/DeleteRecordsCommand.scala   |  4 +-
 .../kafka/admin/ReassignPartitionsCommand.scala    | 72 ++++++++++------------
 .../scala/kafka/admin/ZkSecurityMigrator.scala     |  7 +--
 .../controller/ControllerChannelManager.scala      |  2 +-
 .../kafka/controller/ControllerEventManager.scala  |  3 +-
 .../scala/kafka/controller/KafkaController.scala   |  3 +-
 .../coordinator/group/GroupMetadataManager.scala   |  2 +-
 .../TransactionMarkerChannelManager.scala          |  2 +-
 .../transaction/TransactionStateManager.scala      |  2 +-
 core/src/main/scala/kafka/log/Log.scala            |  4 +-
 core/src/main/scala/kafka/log/LogConfig.scala      |  2 +-
 core/src/main/scala/kafka/log/LogManager.scala     |  2 +-
 .../main/scala/kafka/network/RequestChannel.scala  |  4 +-
 .../main/scala/kafka/network/SocketServer.scala    | 10 +--
 .../kafka/security/auth/SimpleAclAuthorizer.scala  |  9 ++-
 .../src/main/scala/kafka/server/AdminManager.scala | 44 ++++++-------
 .../scala/kafka/server/ClientQuotaManager.scala    |  2 +-
 .../scala/kafka/server/DynamicBrokerConfig.scala   | 12 ++--
 .../src/main/scala/kafka/server/FetchSession.scala | 26 +++-----
 core/src/main/scala/kafka/server/KafkaApis.scala   | 30 ++++-----
 .../main/scala/kafka/server/MetadataCache.scala    |  4 +-
 .../main/scala/kafka/server/ReplicaManager.scala   |  2 +-
 .../main/scala/kafka/tools/EndToEndLatency.scala   |  2 +-
 core/src/main/scala/kafka/tools/MirrorMaker.scala  |  2 +-
 .../kafka/tools/ReplicaVerificationTool.scala      |  2 +-
 .../admin/ReassignPartitionsIntegrationTest.scala  |  4 +-
 .../kafka/api/BaseAdminIntegrationTest.scala       |  4 +-
 .../kafka/api/CustomQuotaCallbackTest.scala        |  4 +-
 .../DelegationTokenEndToEndAuthorizationTest.scala |  2 +-
 .../api/DescribeAuthorizedOperationsTest.scala     |  2 +-
 .../kafka/api/PlaintextAdminIntegrationTest.scala  |  4 +-
 .../SaslClientsWithInvalidCredentialsTest.scala    |  2 +-
 .../kafka/api/SaslSslAdminIntegrationTest.scala    |  2 +-
 .../kafka/api/SslAdminIntegrationTest.scala        |  8 +--
 .../integration/kafka/api/TransactionsTest.scala   |  2 +-
 .../server/DynamicBrokerReconfigurationTest.scala  | 12 ++--
 .../scala/kafka/security/minikdc/MiniKdc.scala     |  4 +-
 .../scala/unit/kafka/admin/ConfigCommandTest.scala |  2 +-
 .../kafka/admin/DelegationTokenCommandTest.scala   |  3 +-
 .../kafka/admin/ReassignPartitionsUnitTest.scala   |  4 +-
 .../controller/ControllerIntegrationTest.scala     |  8 +--
 .../group/GroupMetadataManagerTest.scala           |  4 +-
 core/src/test/scala/unit/kafka/log/LogTest.scala   | 16 ++---
 .../scala/unit/kafka/log/LogValidatorTest.scala    |  6 +-
 .../unit/kafka/network/SocketServerTest.scala      |  2 +-
 .../security/authorizer/AclAuthorizerTest.scala    | 11 ++--
 .../delegation/DelegationTokenManagerTest.scala    |  3 +-
 .../server/AbstractCreateTopicsRequestTest.scala   |  2 +-
 .../DelegationTokenRequestsOnPlainTextTest.scala   |  3 +-
 .../kafka/server/DelegationTokenRequestsTest.scala |  2 +-
 ...nTokenRequestsWithDisableTokenFeatureTest.scala |  3 +-
 .../kafka/server/DeleteTopicsRequestTest.scala     |  2 +-
 .../unit/kafka/server/MetadataRequestTest.scala    |  4 +-
 .../test/scala/unit/kafka/utils/TestUtils.scala    |  9 ++-
 .../unit/kafka/zookeeper/ZooKeeperClientTest.scala |  2 +-
 58 files changed, 195 insertions(+), 218 deletions(-)