This is an automated email from the ASF dual-hosted git repository.
junrao pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from b213c64f97f KAFKA-17480: New consumer commit all consumed should
retrieve offsets in background thread (#17150)
add a0d4cbec402 KAFKA-17743: Add minBytes implementation to
DelayedShareFetch (#17539)
No new revisions were added by this update.
Summary of changes:
.../java/kafka/server/share/DelayedShareFetch.java | 252 +++++++++++----
.../java/kafka/server/share/ShareFetchUtils.java | 12 +-
.../java/kafka/server/share/SharePartition.java | 44 ++-
.../kafka/server/share/SharePartitionManager.java | 15 +-
.../kafka/server/share/DelayedShareFetchTest.java | 351 +++++++++++++++++----
.../kafka/server/share/ShareFetchUtilsTest.java | 42 +--
.../server/share/SharePartitionManagerTest.java | 50 ++-
.../java/kafka/test/api/ShareConsumerTest.java | 2 +-
8 files changed, 606 insertions(+), 162 deletions(-)
