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 5c7cf29 KAFKA-7589: Allow configuring network threads per listener
(#11560)
add 69645f1 KAFKA-13495: Add reason to JoinGroupRequest (KIP-800) (#11566)
No new revisions were added by this update.
Summary of changes:
.../apache/kafka/clients/consumer/Consumer.java | 5 ++
.../kafka/clients/consumer/KafkaConsumer.java | 15 +++++-
.../kafka/clients/consumer/MockConsumer.java | 5 ++
.../consumer/internals/AbstractCoordinator.java | 13 +++++-
.../resources/common/message/JoinGroupRequest.json | 8 +++-
.../common/message/JoinGroupResponse.json | 4 +-
.../internals/AbstractCoordinatorTest.java | 52 ++++++++++++++++++++-
.../kafka/common/requests/RequestResponseTest.java | 4 ++
.../kafka/coordinator/group/GroupCoordinator.scala | 54 +++++++++++++---------
core/src/main/scala/kafka/server/KafkaApis.scala | 1 +
.../scala/unit/kafka/server/KafkaApisTest.scala | 3 ++
11 files changed, 136 insertions(+), 28 deletions(-)
