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 b399a73 KAFKA-7273 Clarification on mutability of headers passed to
Converter#fromConnectData() (#7489)
add de90175 KAFKA-9418; Add new sendOffsetsToTransaction API to
KafkaProducer (#7952)
No new revisions were added by this update.
Summary of changes:
checkstyle/suppressions.xml | 4 +-
.../clients/consumer/ConsumerGroupMetadata.java | 32 ++-
.../kafka/clients/producer/KafkaProducer.java | 57 +++++-
.../kafka/clients/producer/MockProducer.java | 10 +-
.../apache/kafka/clients/producer/Producer.java | 7 +
.../producer/internals/TransactionManager.java | 58 ++++--
.../common/requests/TxnOffsetCommitRequest.java | 36 +++-
.../consumer/ConsumerGroupMetadataTest.java | 45 +++-
.../internals/PartitionAssignorAdapterTest.java | 3 +-
.../kafka/clients/producer/KafkaProducerTest.java | 145 +++++++++++++
.../kafka/clients/producer/MockProducerTest.java | 138 +++++++++++--
.../producer/internals/TransactionManagerTest.java | 228 ++++++++++++++++++++-
.../apache/kafka/common/message/MessageTest.java | 6 +-
.../common/requests/OffsetCommitRequestTest.java | 8 +-
.../kafka/common/requests/RequestResponseTest.java | 37 ++--
.../requests/TxnOffsetCommitRequestTest.java | 86 ++++----
.../kafka/api/TransactionsBounceTest.scala | 18 +-
.../integration/kafka/api/TransactionsTest.scala | 23 ++-
.../coordinator/group/GroupCoordinatorTest.scala | 57 ++++--
.../scala/unit/kafka/server/KafkaApisTest.scala | 13 +-
.../scala/unit/kafka/server/RequestQuotaTest.scala | 14 +-
21 files changed, 868 insertions(+), 157 deletions(-)
