This is an automated email from the ASF dual-hosted git repository.
schofielaj pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 0491e1124ea KAFKA-19892: Client use of ShareAcknowledge acquisition
lock timeout (#20905)
add 108ad6eeeb9 KAFKA-19767 - Send Share-Fetch one-node at a time for
record_limit mode (#20855)
No new revisions were added by this update.
Summary of changes:
.../internals/ShareConsumeRequestManager.java | 45 +++-
.../consumer/internals/SubscriptionState.java | 3 +-
.../internals/ShareConsumeRequestManagerTest.java | 268 +++++++++++----------
3 files changed, 185 insertions(+), 131 deletions(-)