This is an automated email from the ASF dual-hosted git repository.
schofielaj pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 3f8ca851ec8 MINOR: Correct missing space in RecordState exception
message (#20902)
add 5cc4c87be02 KAFKA-19394: Failure in
ConsumerNetworkThread.initializeResources() can cause hangs on
AsyncKafkaConsumer.close() (#20792)
No new revisions were added by this update.
Summary of changes:
.../consumer/internals/AsyncKafkaConsumer.java | 3 +
.../consumer/internals/ConsumerNetworkThread.java | 69 +++++++++++++++++++++-
.../consumer/internals/ShareConsumerImpl.java | 3 +
.../internals/events/ApplicationEventHandler.java | 4 +-
.../kafka/clients/consumer/KafkaConsumerTest.java | 56 ++++++++++++++++++
.../internals/ApplicationEventHandlerTest.java | 57 ++++++++++++++++++
.../consumer/internals/AsyncKafkaConsumerTest.java | 4 +-
.../consumer/internals/ShareConsumerImplTest.java | 59 +++++++++++++++++-
8 files changed, 248 insertions(+), 7 deletions(-)
