public class MetadataServiceCoordinator
extends org.apache.kafka.clients.consumer.internals.AbstractCoordinator
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
PROTOCOL |
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,
java.lang.String metricGrpPrefix,
org.apache.kafka.common.utils.Time time,
MetadataServiceRebalanceListener rebalanceListener) |
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,
java.lang.String memberId,
java.lang.String protocol,
java.nio.ByteBuffer memberAssignment) |
protected void |
onJoinPrepare(int generation,
java.lang.String memberId) |
protected java.util.Map<java.lang.String,java.nio.ByteBuffer> |
performAssignment(java.lang.String coordinationLeaderId,
java.lang.String protocol,
java.util.List<org.apache.kafka.common.message.JoinGroupResponseData.JoinGroupResponseMember> allMemberMetadata) |
protected java.lang.String |
protocolType() |
protected boolean |
rejoinNeededOrPending() |
checkAndGetCoordinator, close, coordinatorUnknown, createMeter, ensureActiveGroup, ensureCoordinatorReady, generation, generationIfStable, isDynamicMember, lookupCoordinator, markCoordinatorUnknown, markCoordinatorUnknown, maybeLeaveGroup, pollHeartbeat, requestRejoin, resetGeneration, timeToNextHeartbeat
public static final java.lang.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, java.lang.String metricGrpPrefix, org.apache.kafka.common.utils.Time time, MetadataServiceRebalanceListener rebalanceListener)
protected java.lang.String protocolType()
protocolType
in class org.apache.kafka.clients.consumer.internals.AbstractCoordinator
protected org.apache.kafka.common.message.JoinGroupRequestData.JoinGroupRequestProtocolCollection metadata()
metadata
in class org.apache.kafka.clients.consumer.internals.AbstractCoordinator
protected void onJoinPrepare(int generation, java.lang.String memberId)
onJoinPrepare
in class org.apache.kafka.clients.consumer.internals.AbstractCoordinator
protected java.util.Map<java.lang.String,java.nio.ByteBuffer> performAssignment(java.lang.String coordinationLeaderId, java.lang.String protocol, java.util.List<org.apache.kafka.common.message.JoinGroupResponseData.JoinGroupResponseMember> allMemberMetadata)
performAssignment
in class org.apache.kafka.clients.consumer.internals.AbstractCoordinator
protected void onJoinComplete(int generation, java.lang.String memberId, java.lang.String protocol, java.nio.ByteBuffer memberAssignment)
onJoinComplete
in class org.apache.kafka.clients.consumer.internals.AbstractCoordinator
protected boolean rejoinNeededOrPending()
rejoinNeededOrPending
in class org.apache.kafka.clients.consumer.internals.AbstractCoordinator
protected void close(org.apache.kafka.common.utils.Timer timer)
close
in class org.apache.kafka.clients.consumer.internals.AbstractCoordinator