You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by jg...@apache.org on 2023/02/21 17:00:45 UTC

[kafka] branch trunk updated (c39123d83d9 -> c9a42c85e2c)

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