This is an automated email from the ASF dual-hosted git repository.
jolshan pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 2fdb6870294 KAFKA-19082: [2/4] Add preparedTxnState class to Kafka
Producer (KIP-939) (#19470)
add 6f783f85362 KAFKA-10551: Add topic id support to produce request and
response (#15968)
No new revisions were added by this update.
Summary of changes:
.../kafka/clients/producer/internals/Sender.java | 24 ++-
.../kafka/common/requests/ProduceRequest.java | 23 +--
.../kafka/common/requests/ProduceResponse.java | 15 +-
.../java/org/apache/kafka/common/utils/Utils.java | 1 +
.../resources/common/message/ProduceRequest.json | 6 +-
.../resources/common/message/ProduceResponse.json | 6 +-
.../kafka/clients/producer/KafkaProducerTest.java | 14 +-
.../clients/producer/internals/SenderTest.java | 148 ++++++++++++-------
.../producer/internals/TransactionManagerTest.java | 5 +-
.../apache/kafka/common/message/MessageTest.java | 12 +-
.../kafka/common/requests/ProduceRequestTest.java | 68 ++++++---
.../kafka/common/requests/ProduceResponseTest.java | 15 +-
.../kafka/common/requests/RequestContextTest.java | 2 +-
.../kafka/common/requests/RequestResponseTest.java | 66 ++++++---
.../group/CoordinatorPartitionWriter.scala | 7 +-
.../transaction/TransactionStateManager.scala | 19 +--
.../main/scala/kafka/server/DelayedProduce.scala | 18 +--
core/src/main/scala/kafka/server/KafkaApis.scala | 80 ++++++----
.../main/scala/kafka/server/ReplicaManager.scala | 161 ++++++++++++---------
.../server/share/SharePartitionManagerTest.java | 8 +-
.../kafka/api/AuthorizerIntegrationTest.scala | 14 +-
.../kafka/api/ProducerSendWhileDeletionTest.scala | 84 ++++++++++-
.../kafka/network/DynamicConnectionQuotaTest.scala | 7 +-
.../kafka/server/LocalLeaderEndPointTest.scala | 27 ++--
.../AbstractCoordinatorConcurrencyTest.scala | 11 +-
.../group/CoordinatorPartitionWriterTest.scala | 25 ++--
.../TransactionCoordinatorConcurrencyTest.scala | 9 +-
.../transaction/TransactionStateManagerTest.scala | 43 ++++--
.../unit/kafka/server/EdgeCaseRequestTest.scala | 6 +-
.../scala/unit/kafka/server/KafkaApisTest.scala | 147 ++++++++++++-------
.../unit/kafka/server/ProduceRequestTest.scala | 39 ++---
.../server/ReplicaManagerConcurrencyTest.scala | 9 +-
.../unit/kafka/server/ReplicaManagerTest.scala | 117 ++++++++-------
.../scala/unit/kafka/server/RequestQuotaTest.scala | 2 +-
.../jmh/producer/ProducerRequestBenchmark.java | 3 +-
.../jmh/producer/ProducerResponseBenchmark.java | 9 +-
36 files changed, 809 insertions(+), 441 deletions(-)
