You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by rs...@apache.org on 2020/08/17 13:36:24 UTC

[kafka] branch trunk updated (e034fed -> e8b2dcd)

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

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


    from e034fed  KAFKA-10387: Fix inclusion of transformation configs when topic creation is enabled in Connect (#9172)
     add e8b2dcd  KAFKA-10023: Enforce broker-wide and per-listener connection creation… (#8768)

No new revisions were added by this update.

Summary of changes:
 .../main/scala/kafka/network/SocketServer.scala    | 142 ++++-
 .../scala/kafka/server/ClientQuotaManager.scala    |   6 +-
 .../kafka/server/ClientRequestQuotaManager.scala   |   3 +-
 .../scala/kafka/server/DynamicBrokerConfig.scala   |   5 +-
 core/src/main/scala/kafka/server/KafkaConfig.scala |   9 +
 core/src/main/scala/kafka/utils/QuotaUtils.scala   |  75 +++
 .../kafka/network/DynamicConnectionQuotaTest.scala | 101 +++-
 .../unit/kafka/network/ConnectionQuotasTest.scala  | 646 +++++++++++++++------
 .../kafka/server/DynamicBrokerConfigTest.scala     |   9 +
 .../scala/unit/kafka/utils/QuotaUtilsTest.scala    | 138 +++++
 10 files changed, 939 insertions(+), 195 deletions(-)
 create mode 100755 core/src/main/scala/kafka/utils/QuotaUtils.scala
 create mode 100755 core/src/test/scala/unit/kafka/utils/QuotaUtilsTest.scala