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 a945bd4 MINOR: Update streamResetter option description (#11613)
add df2236d KAFKA-13412; Ensure initTransactions() safe for retry after
timeout (#11452)
No new revisions were added by this update.
Summary of changes:
.../kafka/clients/producer/KafkaProducer.java | 8 +-
.../producer/internals/TransactionManager.java | 133 ++++---
.../internals/TransactionalRequestResult.java | 34 +-
.../kafka/common/utils/ProducerIdAndEpoch.java | 2 +-
.../kafka/clients/producer/KafkaProducerTest.java | 44 ++-
.../clients/producer/internals/SenderTest.java | 32 +-
.../producer/internals/TransactionManagerTest.java | 417 +++++++++++----------
.../kafka/api/AuthorizerIntegrationTest.scala | 65 ++--
.../integration/kafka/api/TransactionsTest.scala | 4 +-
9 files changed, 421 insertions(+), 318 deletions(-)
