You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by vv...@apache.org on 2022/10/20 02:03:04 UTC
[kafka] branch trunk updated (d0ff8697189 -> 0a045d4ef7d)
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