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 f8d0fc835bf MINOR: Remove addOne to fix build (#13469)
add 5c0e4aa6764 KAFKA-14468: Committed API (#13380)
No new revisions were added by this update.
Summary of changes:
.../consumer/internals/CommitRequestManager.java | 364 ++++++++++++++++++---
.../internals/DefaultBackgroundThread.java | 3 +-
.../consumer/internals/PrototypeAsyncConsumer.java | 79 +++--
.../internals/events/ApplicationEvent.java | 2 +-
.../events/ApplicationEventProcessor.java | 22 +-
.../events/OffsetFetchApplicationEvent.java | 43 +++
.../internals/CommitRequestManagerTest.java | 304 +++++++++++++++--
.../internals/PrototypeAsyncConsumerTest.java | 86 ++++-
.../kafka/api/BaseAsyncConsumerTest.scala | 2 +-
9 files changed, 781 insertions(+), 124 deletions(-)
create mode 100644
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/OffsetFetchApplicationEvent.java
