io.confluent.security.store.kafka.coordinator

Class MetadataServiceCoordinator

java.lang.Object

org.apache.kafka.clients.consumer.internals.AbstractCoordinator

io.confluent.security.store.kafka.coordinator.MetadataServiceCoordinator

All Implemented Interfaces:

Closeable, AutoCloseable

public class MetadataServiceCoordinator
extends org.apache.kafka.clients.consumer.internals.AbstractCoordinator

Coordinator for the Metadata Service used to track active nodes and elect master writer.

Field Summary

Fields

Modifier and Type	Field and Description
static String	PROTOCOL

Fields inherited from class org.apache.kafka.clients.consumer.internals.AbstractCoordinator

HEARTBEAT_THREAD_PREFIX, JOIN_GROUP_TIMEOUT_LAPSE

Constructor Summary

Constructors

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)

Method Summary

Methods inherited from class org.apache.kafka.clients.consumer.internals.AbstractCoordinator

close, coordinatorUnknown, ensureActiveGroup, maybeLeaveGroup, requestRejoin, requestRejoin, requestRejoinIfNecessary

Methods inherited from class java.lang.Object

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

Field Detail

PROTOCOL

public static final String PROTOCOL

See Also:

Constant Field Values

Constructor Detail

MetadataServiceCoordinator

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)