This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 77215eded7b KAFKA-14792: Race condition in LazyIndex.get() (#13359)
add 6fbe4d85a22 KAFKA-14761 Adding integration test for the prototype
consumer (#13303)
No new revisions were added by this update.
Summary of changes:
.../consumer/internals/DefaultEventHandler.java | 1 +
.../consumer/internals/NetworkClientDelegate.java | 18 ++--
.../consumer/internals/PrototypeAsyncConsumer.java | 74 +++++++++++--
.../events/ApplicationEventProcessor.java | 5 +-
.../consumer/internals/events/EventHandler.java | 3 +-
.../internals/PrototypeAsyncConsumerTest.java | 116 +++++++++++++--------
.../kafka/api/AbstractConsumerTest.scala | 10 +-
.../kafka/api/BaseAsyncConsumerTest.scala | 47 +++++++++
.../integration/kafka/api/ConsumerBounceTest.scala | 14 +--
.../kafka/api/IntegrationTestHarness.scala | 21 +++-
.../kafka/api/PlaintextConsumerTest.scala | 10 +-
11 files changed, 234 insertions(+), 85 deletions(-)
create mode 100644
core/src/test/scala/integration/kafka/api/BaseAsyncConsumerTest.scala
