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 5cc4c87be02 KAFKA-19394: Failure in
ConsumerNetworkThread.initializeResources() can cause hangs on
AsyncKafkaConsumer.close() (#20792)
add 0491e1124ea KAFKA-19892: Client use of ShareAcknowledge acquisition
lock timeout (#20905)
No new revisions were added by this update.
Summary of changes:
.../kafka/clients/consumer/ShareConsumerTest.java | 19 ++++++
.../internals/ShareConsumeRequestManager.java | 74 ++++++++++++----------
.../consumer/internals/ShareConsumerImpl.java | 2 +-
.../clients/consumer/internals/ShareFetch.java | 14 +++-
.../events/ShareAcknowledgementEvent.java | 10 ++-
.../internals/ShareConsumeRequestManagerTest.java | 12 ++--
.../consumer/internals/ShareConsumerImplTest.java | 2 +-
.../internals/ShareFetchCollectorTest.java | 3 +-
core/src/main/scala/kafka/server/KafkaApis.scala | 5 +-
9 files changed, 94 insertions(+), 47 deletions(-)
