This is an automated email from the ASF dual-hosted git repository.
vvcephei pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from f4983f4 KAFKA-8930: MirrorMaker v2 documentation (#324) (#9983)
add fdcf8fb KAFKA-10866: Add metadata to ConsumerRecords (#9836)
No new revisions were added by this update.
Summary of changes:
build.gradle | 1 +
checkstyle/suppressions.xml | 5 +-
.../kafka/clients/consumer/ConsumerRecords.java | 105 +++++++++++-
.../kafka/clients/consumer/KafkaConsumer.java | 7 +-
.../kafka/clients/consumer/MockConsumer.java | 17 +-
.../clients/consumer/internals/FetchedRecords.java | 102 +++++++++++
.../kafka/clients/consumer/internals/Fetcher.java | 50 +++---
.../consumer/internals/SubscriptionState.java | 12 ++
.../kafka/clients/consumer/KafkaConsumerTest.java | 189 ++++++++++++++++++---
.../clients/consumer/internals/FetcherTest.java | 28 +--
.../kafka/api/PlaintextConsumerTest.scala | 36 ++--
.../processor/internals/StreamTaskTest.java | 2 +-
12 files changed, 473 insertions(+), 81 deletions(-)
create mode 100644
clients/src/main/java/org/apache/kafka/clients/consumer/internals/FetchedRecords.java
