public class MetadataServiceCoordinator
extends org.apache.kafka.clients.consumer.internals.AbstractCoordinator
Constructor and Description |
---|
MetadataServiceCoordinator(org.apache.kafka.common.utils.LogContext logContext,
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient client,
NodeMetadata nodeMetadata,
org.apache.kafka.clients.consumer.ConsumerConfig consumerConfig,
org.apache.kafka.common.metrics.Metrics metrics,
String metricGrpPrefix,
org.apache.kafka.common.utils.Time time,
MetadataServiceRebalanceListener rebalanceListener) |
public static final String PROTOCOL
public MetadataServiceCoordinator(org.apache.kafka.common.utils.LogContext logContext, org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient client, NodeMetadata nodeMetadata, org.apache.kafka.clients.consumer.ConsumerConfig consumerConfig, org.apache.kafka.common.metrics.Metrics metrics, String metricGrpPrefix, org.apache.kafka.common.utils.Time time, MetadataServiceRebalanceListener rebalanceListener)