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 422bc1f MINOR: Disable JmxTool in kafkatest console-consumer by
default (#7785)
add 63576dd KAFKA-8617: Use automated protocol for `EndTxn` API (#7029)
No new revisions were added by this update.
Summary of changes:
.../producer/internals/TransactionManager.java | 11 ++-
.../org/apache/kafka/common/protocol/ApiKeys.java | 7 +-
.../kafka/common/requests/AbstractResponse.java | 2 +-
.../kafka/common/requests/EndTxnRequest.java | 101 +++++----------------
.../kafka/common/requests/EndTxnResponse.java | 70 ++++++--------
.../clients/producer/internals/SenderTest.java | 11 ++-
.../producer/internals/TransactionManagerTest.java | 20 ++--
.../kafka/common/requests/EndTxnRequestTest.java | 56 ++++++++++++
.../kafka/common/requests/EndTxnResponseTest.java | 50 ++++++++++
.../kafka/common/requests/RequestResponseTest.java | 16 +++-
core/src/main/scala/kafka/server/KafkaApis.scala | 25 +++--
.../scala/unit/kafka/server/RequestQuotaTest.scala | 7 +-
12 files changed, 224 insertions(+), 152 deletions(-)
create mode 100644
clients/src/test/java/org/apache/kafka/common/requests/EndTxnRequestTest.java
create mode 100644
clients/src/test/java/org/apache/kafka/common/requests/EndTxnResponseTest.java