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 68c6c6da862 KAFKA-17767 Store the test catalog in Git [2/n] (2nd
attempt) (#17627)
add 30b1bdfc742 KAFKA-17835 Move ProducerIdManager and
RPCProducerIdManager to transaction-coordinator module (#17562)
No new revisions were added by this update.
Summary of changes:
build.gradle | 7 +-
checkstyle/import-control-server-common.xml | 1 +
.../import-control-transaction-coordinator.xml | 6 +-
.../transaction/ProducerIdManager.scala | 283 ---------------------
.../transaction/TransactionCoordinator.scala | 67 +++--
.../transaction/ZkProducerIdManager.scala | 102 ++++++++
.../scala/kafka/server/AlterPartitionManager.scala | 3 +-
.../kafka/server/AutoTopicCreationManager.scala | 2 +-
.../kafka/server/BrokerLifecycleManager.scala | 2 +-
.../src/main/scala/kafka/server/BrokerServer.scala | 13 +-
.../server/ControllerRegistrationManager.scala | 3 +-
.../main/scala/kafka/server/ControllerServer.scala | 3 +-
.../scala/kafka/server/ForwardingManager.scala | 2 +-
core/src/main/scala/kafka/server/KafkaBroker.scala | 2 +-
core/src/main/scala/kafka/server/KafkaServer.scala | 11 +-
.../server/NodeToControllerChannelManager.scala | 3 +-
.../server/NodeToControllerRequestThreadTest.scala | 2 +-
.../scala/unit/kafka/cluster/PartitionTest.scala | 3 +-
.../transaction/ProducerIdManagerTest.scala | 189 +-------------
.../TransactionCoordinatorConcurrencyTest.scala | 6 +-
.../transaction/TransactionCoordinatorTest.scala | 11 +-
.../kafka/server/AlterPartitionManagerTest.scala | 3 +-
.../server/AutoTopicCreationManagerTest.scala | 2 +-
.../server/BrokerRegistrationRequestTest.scala | 3 +-
.../MockNodeToControllerChannelManager.scala | 2 +-
.../test/scala/unit/kafka/utils/TestUtils.scala | 3 +-
.../ControllerRequestCompletionHandler.java | 2 +-
.../common}/NodeToControllerChannelManager.java | 2 +-
.../apache/kafka/server/AssignmentsManager.java | 2 +
.../kafka/server/AssignmentsManagerTest.java | 2 +
.../coordinator/transaction/ProducerIdManager.java | 42 +++
.../transaction/RPCProducerIdManager.java | 182 +++++++++++++
.../transaction/ProducerIdManagerTest.java | 215 ++++++++++++++++
33 files changed, 632 insertions(+), 549 deletions(-)
delete mode 100644
core/src/main/scala/kafka/coordinator/transaction/ProducerIdManager.scala
create mode 100644
core/src/main/scala/kafka/coordinator/transaction/ZkProducerIdManager.scala
rename {server/src/main/java/org/apache/kafka/server =>
server-common/src/main/java/org/apache/kafka/server/common}/ControllerRequestCompletionHandler.java
(96%)
rename {server/src/main/java/org/apache/kafka/server =>
server-common/src/main/java/org/apache/kafka/server/common}/NodeToControllerChannelManager.java
(96%)
create mode 100644
transaction-coordinator/src/main/java/org/apache/kafka/coordinator/transaction/ProducerIdManager.java
create mode 100644
transaction-coordinator/src/main/java/org/apache/kafka/coordinator/transaction/RPCProducerIdManager.java
create mode 100644
transaction-coordinator/src/test/java/org/apache/kafka/coordinator/transaction/ProducerIdManagerTest.java
