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 e144999 KAFKA-13512: Avoid duplicating maps in ZkMetadataCache topic
accessors
add ddb6959 KAFKA-12980; Return empty record batch from Consumer::poll
when position advances due to aborted transactions (#11046)
No new revisions were added by this update.
Summary of changes:
.../kafka/clients/consumer/KafkaConsumer.java | 30 +++--
.../kafka/clients/consumer/internals/Fetch.java | 123 +++++++++++++++++++++
.../kafka/clients/consumer/internals/Fetcher.java | 49 +++-----
.../clients/consumer/internals/FetcherTest.java | 113 +++++++++++--------
4 files changed, 225 insertions(+), 90 deletions(-)
create mode 100644
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetch.java
