This is an automated email from the ASF dual-hosted git repository.
junrao pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 3b02e97b65e KAFKA-15403: Refactor @Test(expected) annotation with
assertThrows (#14264)
add 945d21953e9 KAFKA-14875: Implement wakeup (#14118)
No new revisions were added by this update.
Summary of changes:
.../consumer/internals/PrototypeAsyncConsumer.java | 54 ++++++++---
.../clients/consumer/internals/WakeupTrigger.java | 105 +++++++++++++++++++++
.../internals/PrototypeAsyncConsumerTest.java | 27 +++++-
.../consumer/internals/WakeupTriggerTest.java | 78 +++++++++++++++
4 files changed, 250 insertions(+), 14 deletions(-)
create mode 100644
clients/src/main/java/org/apache/kafka/clients/consumer/internals/WakeupTrigger.java
create mode 100644
clients/src/test/java/org/apache/kafka/clients/consumer/internals/WakeupTriggerTest.java
