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 2022/09/13 04:02:21 UTC
[kafka] branch trunk updated (b9774c0b025 -> 536cdf692fb)
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 b9774c0b025 KAFKA-14215; Ensure forwarded requests are applied to broker request quota (#12624)
add 536cdf692fb KAFKA-14196; Do not continue fetching partitions awaiting auto-commit prior to revocation (#12603)
No new revisions were added by this update.
Summary of changes:
.../consumer/internals/ConsumerCoordinator.java | 17 ++++++
.../consumer/internals/SubscriptionState.java | 12 +++-
.../clients/consumer/internals/FetcherTest.java | 70 ++++++++++++++++++++++
.../consumer/internals/SubscriptionStateTest.java | 10 ++++
4 files changed, 108 insertions(+), 1 deletion(-)