You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jg...@apache.org on 2020/01/16 21:51:32 UTC
[kafka] branch trunk updated (6d87c12 -> fbe2e60)
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 6d87c12 KAFKA-9410; Make groupId Optional in KafkaConsumer (#7943)
add fbe2e60 KAFKA-9235; Ensure transaction coordinator is stopped after replica deletion (#7963)
No new revisions were added by this update.
Summary of changes:
.../kafka/coordinator/group/GroupCoordinator.scala | 14 ++-
.../transaction/TransactionCoordinator.scala | 89 ++++++++-----
.../transaction/TransactionStateManager.scala | 60 ++++-----
core/src/main/scala/kafka/server/KafkaApis.scala | 25 ++--
.../TransactionCoordinatorConcurrencyTest.scala | 10 +-
.../transaction/TransactionCoordinatorTest.scala | 10 +-
.../transaction/TransactionStateManagerTest.scala | 137 +++++++++++++++++----
.../scala/unit/kafka/server/KafkaApisTest.scala | 37 +++++-
8 files changed, 267 insertions(+), 115 deletions(-)