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

Class RequestManagers

java.lang.Object

org.apache.kafka.clients.consumer.internals.RequestManagers

All Implemented Interfaces:

Closeable, AutoCloseable

public class RequestManagers
extends Object
implements Closeable

RequestManagers provides a means to pass around the set of RequestManager instances in the system. This allows callers to both use the specific RequestManager instance, or to iterate over the list via the entries() method.

Field Summary

Fields

Modifier and Type	Field	Description
final Optional<CommitRequestManager>	commitRequestManager
final Optional<CoordinatorRequestManager>	coordinatorRequestManager
final FetchRequestManager	fetchRequestManager
final Optional<HeartbeatRequestManager>	heartbeatRequestManager
final OffsetsRequestManager	offsetsRequestManager
final TopicMetadataRequestManager	topicMetadataRequestManager

Constructor Summary

Constructors

Constructor	Description
RequestManagers(org.apache.kafka.common.utils.LogContext logContext, OffsetsRequestManager offsetsRequestManager, TopicMetadataRequestManager topicMetadataRequestManager, FetchRequestManager fetchRequestManager, Optional<CoordinatorRequestManager> coordinatorRequestManager, Optional<CommitRequestManager> commitRequestManager, Optional<HeartbeatRequestManager> heartbeatRequestManager)

Method Summary

Modifier and Type	Method	Description
void	close()
List<Optional<? extends RequestManager>>	entries()
static Supplier<RequestManagers>	supplier(org.apache.kafka.common.utils.Time time, org.apache.kafka.common.utils.LogContext logContext, BackgroundEventHandler backgroundEventHandler, ConsumerMetadata metadata, SubscriptionState subscriptions, FetchBuffer fetchBuffer, ConsumerConfig config, org.apache.kafka.clients.GroupRebalanceConfig groupRebalanceConfig, org.apache.kafka.clients.ApiVersions apiVersions, FetchMetricsManager fetchMetricsManager, Supplier<NetworkClientDelegate> networkClientDelegateSupplier, Optional<org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter> clientTelemetryReporter)	Creates a Supplier for deferred creation during invocation by ConsumerNetworkThread.

Methods inherited from class java.lang.Object

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

Field Details

coordinatorRequestManager

public final Optional<CoordinatorRequestManager> coordinatorRequestManager

commitRequestManager

public final Optional<CommitRequestManager> commitRequestManager

heartbeatRequestManager

public final Optional<HeartbeatRequestManager> heartbeatRequestManager

offsetsRequestManager

public final OffsetsRequestManager offsetsRequestManager

topicMetadataRequestManager

public final TopicMetadataRequestManager topicMetadataRequestManager

fetchRequestManager

public final FetchRequestManager fetchRequestManager

Constructor Details

RequestManagers

public RequestManagers(org.apache.kafka.common.utils.LogContext logContext,
 OffsetsRequestManager offsetsRequestManager,
 TopicMetadataRequestManager topicMetadataRequestManager,
 FetchRequestManager fetchRequestManager,
 Optional<CoordinatorRequestManager> coordinatorRequestManager,
 Optional<CommitRequestManager> commitRequestManager,
 Optional<HeartbeatRequestManager> heartbeatRequestManager)

Method Details

entries

public List<Optional<? extends RequestManager>> entries()

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

supplier

public static Supplier<RequestManagers> supplier(org.apache.kafka.common.utils.Time time,
 org.apache.kafka.common.utils.LogContext logContext,
 BackgroundEventHandler backgroundEventHandler,
 ConsumerMetadata metadata,
 SubscriptionState subscriptions,
 FetchBuffer fetchBuffer,
 ConsumerConfig config,
 org.apache.kafka.clients.GroupRebalanceConfig groupRebalanceConfig,
 org.apache.kafka.clients.ApiVersions apiVersions,
 FetchMetricsManager fetchMetricsManager,
 Supplier<NetworkClientDelegate> networkClientDelegateSupplier,
 Optional<org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter> clientTelemetryReporter)

Creates a Supplier for deferred creation during invocation by ConsumerNetworkThread.