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%)
