This is an automated email from the ASF dual-hosted git repository. jgus pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git
from c39123d83d9 KAKFA-14733: Added a few missing checks for Kraft Authorizer and updated AclAuthorizerTest to run tests for both zk and kraft (#13282) add c9a42c85e2c KAFKA-14675: Extract metadata-related tasks from Fetcher into MetadataFetcher 1/4 (#13192) No new revisions were added by this update. Summary of changes: .../kafka/clients/consumer/KafkaConsumer.java | 50 +- .../kafka/clients/consumer/internals/Fetcher.java | 752 +----- .../clients/consumer/internals/OffsetFetcher.java | 717 ++++++ .../consumer/internals/SubscriptionState.java | 2 +- .../consumer/internals/TopicMetadataFetcher.java | 160 ++ .../kafka/clients/consumer/KafkaConsumerTest.java | 14 +- .../clients/consumer/internals/FetcherTest.java | 2544 ++++---------------- .../consumer/internals/OffsetFetcherTest.java | 1736 +++++++++++++ .../internals/TopicMetadataFetcherTest.java | 259 ++ 9 files changed, 3363 insertions(+), 2871 deletions(-) create mode 100644 clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetFetcher.java create mode 100644 clients/src/main/java/org/apache/kafka/clients/consumer/internals/TopicMetadataFetcher.java create mode 100644 clients/src/test/java/org/apache/kafka/clients/consumer/internals/OffsetFetcherTest.java create mode 100644 clients/src/test/java/org/apache/kafka/clients/consumer/internals/TopicMetadataFetcherTest.java