You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by da...@apache.org on 2020/11/19 15:33:20 UTC

[kafka] branch trunk updated (91679f2 -> 1841e9f)

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

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


    from 91679f2  KAFKA-10692: Add delegation.token.secret.key, deprecate ...master.key (#9623)
     add 1841e9f  KAFKA-10024: Add dynamic configuration and enforce quota for per-IP connection rate limits (KIP-612, part 2) (#9386)

No new revisions were added by this update.

Summary of changes:
 .../main/scala/kafka/network/SocketServer.scala    | 331 +++++++++++++++-----
 .../main/scala/kafka/server/ConfigHandler.scala    |  20 ++
 .../main/scala/kafka/server/DynamicConfig.scala    |  16 +
 .../scala/kafka/server/DynamicConfigManager.scala  |   3 +-
 core/src/main/scala/kafka/server/KafkaServer.scala |   3 +-
 core/src/main/scala/kafka/zk/AdminZkClient.scala   |  24 ++
 .../kafka/network/DynamicConnectionQuotaTest.scala |  49 ++-
 .../unit/kafka/network/ConnectionQuotasTest.scala  | 342 ++++++++++++++++++---
 .../unit/kafka/network/SocketServerTest.scala      |  79 ++++-
 .../kafka/server/DynamicConfigChangeTest.scala     |  68 ++++
 .../unit/kafka/server/DynamicConfigTest.scala      |  13 +-
 11 files changed, 811 insertions(+), 137 deletions(-)