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

Posted to commits@kafka.apache.org by ch...@apache.org on 2024/07/01 15:32:00 UTC

(kafka) branch trunk updated (7d91bc8cf9f -> 206d0f809ad)

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

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


    from 7d91bc8cf9f KAFKA-17046 Upgrade netty version to 4.1.111.Final (#16469)
     add 206d0f809ad KAFKA-16909 Refactor GroupCoordinatorConfig with AbstractConfig (#16458)

No new revisions were added by this update.

Summary of changes:
 .../kafka/coordinator/group/GroupCoordinator.scala |  28 ++--
 .../kafka/server/AutoTopicCreationManager.scala    |   4 +-
 .../src/main/scala/kafka/server/BrokerServer.scala |  26 +--
 core/src/main/scala/kafka/server/KafkaApis.scala   |   2 +-
 core/src/main/scala/kafka/server/KafkaConfig.scala |  53 ++----
 core/src/main/scala/kafka/server/KafkaServer.scala |   2 +-
 .../server/metadata/BrokerMetadataPublisher.scala  |   2 +-
 .../server/DynamicBrokerReconfigurationTest.scala  |   2 +-
 .../group/GroupCoordinatorConcurrencyTest.scala    |   4 +-
 .../coordinator/group/GroupCoordinatorTest.scala   |   2 +-
 .../group/GroupMetadataManagerTest.scala           |  20 +--
 .../kafka/integration/KafkaServerTestHarness.scala |   4 +-
 .../server/AutoTopicCreationManagerTest.scala      |   2 +-
 .../scala/unit/kafka/server/KafkaConfigTest.scala  |   6 +-
 .../coordinator/group/GroupCoordinatorConfig.java  | 181 ++++++++++++++-------
 .../coordinator/group/GroupCoordinatorService.java |  38 ++---
 .../coordinator/group/GroupCoordinatorShard.java   |  24 +--
 .../coordinator/group/OffsetMetadataManager.java   |   4 +-
 .../group/GroupCoordinatorConfigTest.java          | 148 ++++++++++-------
 .../group/GroupCoordinatorServiceTest.java         |  23 +--
 .../group/OffsetMetadataManagerTest.java           |  21 +--
 21 files changed, 312 insertions(+), 284 deletions(-)