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