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.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.kafka.clients.consumer.internals.AbstractCoordinator

org.apache.kafka.clients.consumer.internals.AbstractCoordinator.CoordinatorResponseHandler<R,T>, org.apache.kafka.clients.consumer.internals.AbstractCoordinator.Generation, org.apache.kafka.clients.consumer.internals.AbstractCoordinator.MemberState

Field Summary

Fields

Modifier and Type	Field and Description
static String	PROTOCOL

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

client, HEARTBEAT_THREAD_PREFIX, JOIN_GROUP_TIMEOUT_LAPSE, state, time

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

Modifier and Type	Method and Description
protected void	close(org.apache.kafka.common.utils.Timer timer)
protected org.apache.kafka.common.message.JoinGroupRequestData.JoinGroupRequestProtocolCollection	metadata()
protected void	onJoinComplete(int generation, String memberId, String protocol, ByteBuffer memberAssignment)
protected boolean	onJoinPrepare(org.apache.kafka.common.utils.Timer timer, int generation, String memberId)
protected Map<String,ByteBuffer>	onLeaderElected(String coordinationLeaderId, String protocol, List<org.apache.kafka.common.message.JoinGroupResponseData.JoinGroupResponseMember> allMemberMetadata, boolean skipAssignment)
protected String	protocolType()
protected boolean	rejoinNeededOrPending()

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

checkAndGetCoordinator, close, coordinatorUnknown, createMeter, ensureActiveGroup, ensureCoordinatorReady, ensureCoordinatorReadyAsync, generation, generationIfStable, isDynamicMember, lookupCoordinator, markCoordinatorUnknown, markCoordinatorUnknown, markCoordinatorUnknown, maybeLeaveGroup, memberId, onLeavePrepare, pollHeartbeat, rebalanceInProgress, requestRejoin, requestRejoin, requestRejoinIfNecessary, timeToNextHeartbeat

Methods inherited from class java.lang.Object

clone, equals, finalize, 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)

Method Detail

protocolType

protected String protocolType()

Specified by:

protocolType in class org.apache.kafka.clients.consumer.internals.AbstractCoordinator

metadata

protected org.apache.kafka.common.message.JoinGroupRequestData.JoinGroupRequestProtocolCollection metadata()

Specified by:

metadata in class org.apache.kafka.clients.consumer.internals.AbstractCoordinator

onJoinPrepare

protected boolean onJoinPrepare(org.apache.kafka.common.utils.Timer timer,
                                int generation,
                                String memberId)

Specified by:

onJoinPrepare in class org.apache.kafka.clients.consumer.internals.AbstractCoordinator

onLeaderElected

protected Map<String,ByteBuffer> onLeaderElected(String coordinationLeaderId,
                                                 String protocol,
                                                 List<org.apache.kafka.common.message.JoinGroupResponseData.JoinGroupResponseMember> allMemberMetadata,
                                                 boolean skipAssignment)

Specified by:

onLeaderElected in class org.apache.kafka.clients.consumer.internals.AbstractCoordinator

onJoinComplete

protected void onJoinComplete(int generation,
                              String memberId,
                              String protocol,
                              ByteBuffer memberAssignment)

Specified by:

onJoinComplete in class org.apache.kafka.clients.consumer.internals.AbstractCoordinator

rejoinNeededOrPending

protected boolean rejoinNeededOrPending()

Overrides:

rejoinNeededOrPending in class org.apache.kafka.clients.consumer.internals.AbstractCoordinator

close

protected void close(org.apache.kafka.common.utils.Timer timer)

Overrides:

close in class org.apache.kafka.clients.consumer.internals.AbstractCoordinator