Package org.apache.kafka.clients.consumer.internals

Class ConsumerMetadata

java.lang.Object
org.apache.kafka.clients.Metadata
org.apache.kafka.clients.consumer.internals.ConsumerMetadata
All Implemented Interfaces:
Closeable, AutoCloseable
public class ConsumerMetadata extends org.apache.kafka.clients.Metadata

  • Nested Class Summary

    Nested classes/interfaces inherited from class org.apache.kafka.clients.Metadata

    org.apache.kafka.clients.Metadata.LeaderAndEpoch, org.apache.kafka.clients.Metadata.LeaderIdAndEpoch, org.apache.kafka.clients.Metadata.MetadataRequestAndVersion

  • Constructor Summary

    Constructors
    Constructor
    Description
    ConsumerMetadata(long refreshBackoffMs, long refreshBackoffMaxMs, long metadataExpireMs, boolean includeInternalTopics, boolean allowAutoTopicCreation, SubscriptionState subscription, org.apache.kafka.common.utils.LogContext logContext, org.apache.kafka.common.internals.ClusterResourceListeners clusterResourceListeners)
     
    ConsumerMetadata(ConsumerConfig config, SubscriptionState subscriptions, org.apache.kafka.common.utils.LogContext logContext, org.apache.kafka.common.internals.ClusterResourceListeners clusterResourceListeners)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    boolean
    allowAutoTopicCreation()
     
    org.apache.kafka.common.requests.MetadataRequest.Builder
    newMetadataRequestBuilder()
     
    protected boolean
    retainTopic(String topic, boolean isInternal, long nowMs)
     

    Methods inherited from class org.apache.kafka.clients.Metadata

    addClusterUpdateListener, bootstrap, close, currentLeader, failedUpdate, fatalError, fetch, isClosed, lastSeenLeaderEpoch, lastSuccessfulUpdate, maybeThrowAnyException, maybeThrowExceptionForTopic, maybeThrowFatalException, metadataExpireMs, newMetadataRequestAndVersion, newMetadataRequestBuilderForNewTopics, requestUpdate, requestUpdateForNewTopics, timeToAllowUpdate, timeToNextUpdate, topicIds, topicNames, update, updateLastSeenEpochIfNewer, updatePartitionLeadership, updateRequested, updateVersion, updateWithCurrentRequestVersion

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • ConsumerMetadata

      public ConsumerMetadata(long refreshBackoffMs, long refreshBackoffMaxMs, long metadataExpireMs, boolean includeInternalTopics, boolean allowAutoTopicCreation, SubscriptionState subscription, org.apache.kafka.common.utils.LogContext logContext, org.apache.kafka.common.internals.ClusterResourceListeners clusterResourceListeners)

    • ConsumerMetadata

      public ConsumerMetadata(ConsumerConfig config, SubscriptionState subscriptions, org.apache.kafka.common.utils.LogContext logContext, org.apache.kafka.common.internals.ClusterResourceListeners clusterResourceListeners)

  • Method Details

    • allowAutoTopicCreation

      public boolean allowAutoTopicCreation()

    • newMetadataRequestBuilder

      public org.apache.kafka.common.requests.MetadataRequest.Builder newMetadataRequestBuilder()
      Overrides:
      newMetadataRequestBuilder in class org.apache.kafka.clients.Metadata

    • retainTopic

      protected boolean retainTopic(String topic, boolean isInternal, long nowMs)
      Overrides:
      retainTopic in class org.apache.kafka.clients.Metadata