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 dc512cc  KAFKA-13015: Ducktape System Tests for Metadata Snapshots 
(#11053)
     add 9baf5eb  KAFKA-13008: Try to refresh end offset when partitionLag 
returns empty (#11057)

No new revisions were added by this update.

Summary of changes:
 .../kafka/clients/consumer/KafkaConsumer.java      | 19 ++++++-
 .../kafka/clients/consumer/internals/Fetcher.java  | 59 +++++++++++++++++-----
 .../consumer/internals/SubscriptionState.java      | 33 +++++++++++-
 .../kafka/clients/consumer/KafkaConsumerTest.java  | 50 +++++++++++++++++-
 .../clients/consumer/internals/FetcherTest.java    | 17 ++++++-
 5 files changed, 162 insertions(+), 16 deletions(-)

Reply via email to