This is an automated email from the ASF dual-hosted git repository.
schofielaj pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 08f6042f7a2 HOTFIX: Fix IQv2EndpointToPartitionsIntegrationTest
(#19597)
add ce97b1d5e71 KAFKA-16894: Exploit share feature [3/N] (#19542)
No new revisions were added by this update.
Summary of changes:
.../kafka/clients/consumer/ShareConsumerTest.java | 10 +-
.../kafka/server/builders/KafkaApisBuilder.java | 10 +-
.../kafka/server/AutoTopicCreationManager.scala | 8 +-
.../src/main/scala/kafka/server/BrokerServer.scala | 64 ++-
core/src/main/scala/kafka/server/KafkaApis.scala | 117 ++---
.../server/metadata/BrokerMetadataPublisher.scala | 40 +-
.../kafka/api/IntegrationTestHarness.scala | 4 -
.../server/AutoTopicCreationManagerTest.scala | 22 +-
.../scala/unit/kafka/server/KafkaApisTest.scala | 490 ++++++++-------------
.../scala/unit/kafka/server/KafkaConfigTest.scala | 2 -
.../server/ShareFetchAcknowledgeRequestTest.scala | 111 +----
.../server/ShareGroupDescribeRequestTest.scala | 9 +-
.../server/ShareGroupHeartbeatRequestTest.scala | 19 +-
.../metadata/BrokerMetadataPublisherTest.scala | 2 +-
.../group/modern/share/ShareGroupConfig.java | 14 +-
.../group/modern/share/ShareGroupConfigTest.java | 1 -
tests/kafkatest/services/kafka/kafka.py | 1 -
.../org/apache/kafka/tools/GroupsCommandTest.java | 2 +-
18 files changed, 315 insertions(+), 611 deletions(-)
