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 6495a0768ca KAFKA-14032; Dequeue time for forwarded requests is unset
(#12360)
add 915c7812439 KAFKA-10199: Remove main consumer from store changelog
reader (#12337)
No new revisions were added by this update.
Summary of changes:
.../kafka/clients/admin/KafkaAdminClient.java | 2 +-
.../admin/ListConsumerGroupOffsetsOptions.java | 13 ++++
.../internals/ListConsumerGroupOffsetsHandler.java | 15 ++++-
.../kafka/clients/admin/AdminClientTestUtils.java | 7 +++
.../kafka/clients/admin/KafkaAdminClientTest.java | 33 ++++++++++
.../kafka/clients/admin/MockAdminClient.java | 38 ++++++++++--
.../processor/internals/DefaultStateUpdater.java | 3 +-
.../processor/internals/StoreChangelogReader.java | 71 ++++++++++++----------
.../streams/processor/internals/StreamThread.java | 1 -
.../internals/DefaultStateUpdaterTest.java | 1 +
.../processor/internals/StandbyTaskTest.java | 8 ++-
.../internals/StoreChangelogReaderTest.java | 50 ++++++---------
.../processor/internals/StreamTaskTest.java | 27 +++++++-
13 files changed, 188 insertions(+), 81 deletions(-)
