This is an automated email from the ASF dual-hosted git repository.
manikumar pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 2beadc8bd0c KAFKA-17695 cleanup org.apache.kafka.common.test.TestUtils
(#17364)
add 7c34cf6e2cb KAFKA-17664: Added check before sending background event
after ShareAcknowledge (#17332)
No new revisions were added by this update.
Summary of changes:
.../internals/ShareConsumeRequestManager.java | 24 ++++++---
.../consumer/internals/ShareConsumerImpl.java | 9 ++++
.../internals/events/ApplicationEvent.java | 1 +
.../events/ApplicationEventProcessor.java | 18 +++++++
...wledgementCommitCallbackRegistrationEvent.java} | 21 +++-----
.../internals/ShareConsumeRequestManagerTest.java | 59 ++++++++++++++++++++++
.../consumer/internals/ShareConsumerImplTest.java | 39 ++++++++++++++
7 files changed, 151 insertions(+), 20 deletions(-)
copy
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/{PollEvent.java
=> ShareAcknowledgementCommitCallbackRegistrationEvent.java} (66%)
