You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by jg...@apache.org on 2021/12/09 04:38:28 UTC

[kafka] branch trunk updated (e144999 -> ddb6959)

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