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 8d32a0f2463 [KAFKA-14685] Refactor logic to handle
OFFSET_MOVED_TO_TIERED_STORAGE error (#13206)
add 62431dca700 KAFKA-14468: Implement CommitRequestManager to manage the
commit and autocommit requests (#13021)
No new revisions were added by this update.
Summary of changes:
.../consumer/internals/CommitRequestManager.java | 238 +++++++++++++++++++++
.../internals/DefaultBackgroundThread.java | 86 +++++---
.../clients/consumer/internals/GroupState.java | 89 ++++++++
.../consumer/internals/NetworkClientDelegate.java | 16 +-
.../consumer/internals/PrototypeAsyncConsumer.java | 37 ++--
.../clients/consumer/internals/RequestManager.java | 4 +
.../internals/events/ApplicationEvent.java | 2 +-
.../events/ApplicationEventProcessor.java | 47 +++-
.../internals/events/CommitApplicationEvent.java | 64 ++++++
...kgroundEvent.java => PollApplicationEvent.java} | 10 +-
.../internals/CommitRequestManagerTest.java | 139 ++++++++++++
.../internals/DefaultBackgroundThreadTest.java | 41 +++-
12 files changed, 700 insertions(+), 73 deletions(-)
create mode 100644
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java
create mode 100644
clients/src/main/java/org/apache/kafka/clients/consumer/internals/GroupState.java
create mode 100644
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/CommitApplicationEvent.java
copy
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/{ErrorBackgroundEvent.java
=> PollApplicationEvent.java} (79%)
create mode 100644
clients/src/test/java/org/apache/kafka/clients/consumer/internals/CommitRequestManagerTest.java
