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 9ae1b0f0178 KAFKA-18134; Disallow group upgrades when custom assignors
are used (#18046)
add d76238a18fb KAFKA-17696 New consumer background operations unaware of
metadata errors (#17440)
No new revisions were added by this update.
Summary of changes:
.../consumer/internals/AsyncKafkaConsumer.java | 15 ++++-----
.../consumer/internals/ConsumerNetworkThread.java | 29 +++++++++++++++--
.../consumer/internals/NetworkClientDelegate.java | 24 ++++++++++++---
.../consumer/internals/ShareConsumerImpl.java | 5 +--
.../events/CheckAndUpdatePositionsEvent.java | 14 +++++++++
.../events/CompletableApplicationEvent.java | 4 +++
.../internals/events/CompletableEventReaper.java | 8 +++++
.../internals/events/ListOffsetsEvent.java | 5 +++
.../consumer/internals/AsyncKafkaConsumerTest.java | 36 ----------------------
.../internals/FetchRequestManagerTest.java | 7 +++--
.../internals/NetworkClientDelegateTest.java | 35 +++++++++++++++------
.../internals/ShareConsumeRequestManagerTest.java | 8 +++--
.../kafka/api/AuthorizerIntegrationTest.scala | 10 +++---
.../kafka/api/EndToEndAuthorizationTest.scala | 20 ++++++------
.../kafka/api/SaslEndToEndAuthorizationTest.scala | 2 +-
.../kafka/server/QuorumTestHarness.scala | 2 +-
16 files changed, 139 insertions(+), 85 deletions(-)
