This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 6ddbf4d KAFKA-9809: Shrink transaction timeout for streams (#8407) add 7f640f1 KAFKA-9776: Downgrade TxnCommit API v3 when broker doesn't support (#8375) No new revisions were added by this update. Summary of changes: .../kafka/clients/producer/KafkaProducer.java | 26 +- .../kafka/clients/producer/ProducerConfig.java | 21 +- .../producer/internals/TransactionManager.java | 29 +- .../common/requests/TxnOffsetCommitRequest.java | 39 +- .../kafka/clients/producer/KafkaProducerTest.java | 42 +- .../producer/internals/RecordAccumulatorTest.java | 2 +- .../clients/producer/internals/SenderTest.java | 18 +- .../producer/internals/TransactionManagerTest.java | 825 +++++++++------------ .../kafka/common/requests/RequestResponseTest.java | 30 +- .../requests/TxnOffsetCommitRequestTest.java | 69 +- .../scala/unit/kafka/server/KafkaApisTest.scala | 6 +- .../scala/unit/kafka/server/RequestQuotaTest.scala | 15 +- .../org/apache/kafka/streams/StreamsConfig.java | 5 + .../apache/kafka/streams/StreamsConfigTest.java | 22 + .../streams/streams_broker_compatibility_test.py | 6 +- 15 files changed, 579 insertions(+), 576 deletions(-)