Class RequestManagers
java.lang.Object
org.apache.kafka.clients.consumer.internals.RequestManagers
- All Implemented Interfaces:
Closeable,AutoCloseable
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
FieldsModifier and TypeFieldDescriptionfinal Optional<CommitRequestManager> final FetchRequestManagerfinal Optional<HeartbeatRequestManager> final OffsetsRequestManager -
Constructor Summary
ConstructorsConstructorDescriptionRequestManagers(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 TypeMethodDescriptionvoidclose()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 aSupplierfor deferred creation during invocation byConsumerNetworkThread.
-
Field Details
-
coordinatorRequestManager
-
commitRequestManager
-
heartbeatRequestManager
-
offsetsRequestManager
-
topicMetadataRequestManager
-
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
-
close
public void close()- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable
-
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 aSupplierfor deferred creation during invocation byConsumerNetworkThread.
-