You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ij...@apache.org on 2020/05/11 14:27:33 UTC
[kafka] branch trunk updated (5583089 -> 847ff8f)
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(-)