This is an automated email from the ASF dual-hosted git repository.
vvcephei pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from d0ff8697189 MINOR; Add accessor methods to OffsetAndEpoch (#12770)
add 0a045d4ef7d KAFKA-14247: Consumer background thread base
implementation (#12672)
No new revisions were added by this update.
Summary of changes:
.../internals/DefaultBackgroundThread.java | 230 +++++++++++++++++++++
.../consumer/internals/DefaultEventHandler.java | 170 +++++++++++++--
...lanceListener.java => NoopBackgroundEvent.java} | 22 +-
.../consumer/internals/PrototypeAsyncConsumer.java | 28 ++-
.../internals/events/ApplicationEvent.java | 6 +
.../consumer/internals/events/BackgroundEvent.java | 8 +
.../consumer/internals/events/EventHandler.java | 1 -
.../internals/events/NoopApplicationEvent.java | 31 ++-
.../internals/DefaultBackgroundThreadTest.java | 171 +++++++++++++++
.../internals/DefaultEventHandlerTest.java | 116 +++++++++++
10 files changed, 732 insertions(+), 51 deletions(-)
create mode 100644
clients/src/main/java/org/apache/kafka/clients/consumer/internals/DefaultBackgroundThread.java
copy
clients/src/main/java/org/apache/kafka/clients/consumer/internals/{NoOpConsumerRebalanceListener.java
=> NoopBackgroundEvent.java} (65%)
copy trogdor/src/main/java/org/apache/kafka/trogdor/rest/Empty.java =>
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/NoopApplicationEvent.java
(52%)
create mode 100644
clients/src/test/java/org/apache/kafka/clients/consumer/internals/DefaultBackgroundThreadTest.java
create mode 100644
clients/src/test/java/org/apache/kafka/clients/consumer/internals/DefaultEventHandlerTest.java
