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