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 aa0d0ec KAFKA-6607: Commit correct offsets for transactional input data (#8091) add 07db26c KAFKA-9417: New Integration Test for KIP-447 (#8000) No new revisions were added by this update. Summary of changes: checkstyle/suppressions.xml | 2 +- .../consumer/internals/ConsumerCoordinator.java | 2 +- .../kafka/clients/consumer/internals/Fetcher.java | 11 +- .../producer/internals/TransactionManager.java | 2 + .../kafka/coordinator/group/GroupCoordinator.scala | 4 +- .../transaction/TransactionStateManager.scala | 2 +- .../main/scala/kafka/tools/ConsoleConsumer.scala | 10 +- .../examples/ExactlyOnceMessageProcessor.java | 5 +- .../kafka/examples/KafkaConsumerProducerDemo.java | 2 +- .../java/kafka/examples/KafkaExactlyOnceDemo.java | 2 +- .../src/main/java/kafka/examples/Producer.java | 4 + tests/docker/ducker-ak | 2 + tests/kafkatest/services/console_consumer.py | 13 +- tests/kafkatest/services/kafka/kafka.py | 2 +- .../services/transactional_message_copier.py | 16 +- tests/kafkatest/services/verifiable_producer.py | 14 +- ...ons_test.py => group_mode_transactions_test.py} | 171 +++++++++++++-------- tests/kafkatest/tests/core/transactions_test.py | 34 ++-- .../kafka/tools/TransactionalMessageCopier.java | 153 ++++++++++++------ .../org/apache/kafka/tools/VerifiableConsumer.java | 10 +- 20 files changed, 316 insertions(+), 145 deletions(-) copy tests/kafkatest/tests/core/{transactions_test.py => group_mode_transactions_test.py} (60%)