This is an automated email from the ASF dual-hosted git repository.
davidarthur pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from aa25176 MINOR: Kafka Streams code samples formating unification
(#10651)
add 72d1082 KAFKA-12620 Allocate producer ids on the controller (#10504)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/common/protocol/ApiKeys.java | 3 +-
.../kafka/common/requests/AbstractRequest.java | 2 +
.../kafka/common/requests/AbstractResponse.java | 2 +
...equest.java => AllocateProducerIdsRequest.java} | 45 ++--
...ponse.java => AllocateProducerIdsResponse.java} | 52 ++---
...equest.json => AllocateProducerIdsRequest.json} | 12 +-
...ponse.json => AllocateProducerIdsResponse.json} | 19 +-
.../apache/kafka/common/protocol/ApiKeysTest.java | 2 +-
core/src/main/scala/kafka/api/ApiVersion.scala | 13 +-
.../scala/kafka/controller/KafkaController.scala | 64 +++++-
.../transaction/ProducerIdManager.scala | 255 ++++++++++++++-------
.../transaction/TransactionCoordinator.scala | 14 +-
.../scala/kafka/network/RequestConvertToJson.scala | 2 +
.../src/main/scala/kafka/server/BrokerServer.scala | 6 +-
core/src/main/scala/kafka/server/KafkaApis.scala | 17 ++
core/src/main/scala/kafka/server/KafkaServer.scala | 44 ++--
core/src/main/scala/kafka/zk/ZkData.scala | 28 ++-
core/src/test/java/kafka/test/ClusterConfig.java | 26 ++-
core/src/test/java/kafka/test/ClusterInstance.java | 2 +
.../java/kafka/test/annotation/ClusterTest.java | 1 +
.../kafka/test/junit/ClusterTestExtensions.java | 6 +-
.../test/junit/RaftClusterInvocationContext.java | 21 +-
.../test/junit/ZkClusterInvocationContext.java | 26 ++-
core/src/test/java/kafka/testkit/BrokerNode.java | 8 +
.../java/kafka/testkit/KafkaClusterTestKit.java | 1 +
.../transaction/ProducerIdsIntegrationTest.scala | 85 +++++++
.../transaction/ProducerIdManagerTest.scala | 94 ++++++--
.../TransactionCoordinatorConcurrencyTest.scala | 2 +-
.../transaction/TransactionCoordinatorTest.scala | 2 +-
.../kafka/integration/KafkaServerTestHarness.scala | 13 +-
.../scala/unit/kafka/server/RequestQuotaTest.scala | 7 +-
.../kafka/server/common/ProducerIdsBlock.java | 80 +++++++
32 files changed, 733 insertions(+), 221 deletions(-)
copy
clients/src/main/java/org/apache/kafka/common/requests/{CreateDelegationTokenRequest.java
=> AllocateProducerIdsRequest.java} (54%)
copy
clients/src/main/java/org/apache/kafka/common/requests/{HeartbeatResponse.java
=> AllocateProducerIdsResponse.java} (58%)
copy clients/src/main/resources/common/message/{UnregisterBrokerRequest.json
=> AllocateProducerIdsRequest.json} (76%)
copy clients/src/main/resources/common/message/{EndTxnResponse.json =>
AllocateProducerIdsResponse.json} (71%)
create mode 100644
core/src/test/scala/integration/kafka/coordinator/transaction/ProducerIdsIntegrationTest.scala
create mode 100644
server-common/src/main/java/org/apache/kafka/server/common/ProducerIdsBlock.java
