This is an automated email from the ASF dual-hosted git repository.
lianetm pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 8ebb9d80a06 Revert "MINOR: Ensure CI runs on weekends (#17396)"
add 435e9851d2b KAFKA-17505: New consumer seekToBeginning/End should run
in background thread (#17230)
No new revisions were added by this update.
Summary of changes:
.../consumer/internals/AsyncKafkaConsumer.java | 21 ++++----
.../internals/events/ApplicationEvent.java | 2 +-
.../events/ApplicationEventProcessor.java | 16 ++++++
.../internals/events/ResetOffsetEvent.java | 60 ++++++++++++++++++++++
.../consumer/internals/AsyncKafkaConsumerTest.java | 50 ++++++++++++++++++
.../events/ApplicationEventProcessorTest.java | 13 +++++
.../kafka/api/PlaintextConsumerTest.scala | 9 ++++
7 files changed, 158 insertions(+), 13 deletions(-)
create mode 100644
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ResetOffsetEvent.java
