public class MetadataServiceCoordinator
extends 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
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) |
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 void |
onJoinPrepare(int generation,
String memberId) |
protected Map<String,ByteBuffer> |
performAssignment(String coordinationLeaderId,
String protocol,
List<org.apache.kafka.common.message.JoinGroupResponseData.JoinGroupResponseMember> allMemberMetadata) |
protected String |
protocolType() |
protected boolean |
rejoinNeededOrPending() |
checkAndGetCoordinator, close, coordinatorUnknown, createMeter, ensureActiveGroup, ensureCoordinatorReady, generation, generationIfStable, isDynamicMember, lookupCoordinator, markCoordinatorUnknown, markCoordinatorUnknown, markCoordinatorUnknown, maybeLeaveGroup, memberId, onLeavePrepare, pollHeartbeat, rebalanceInProgress, requestRejoin, timeToNextHeartbeat
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)
protected 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, String memberId)
onJoinPrepare
in class org.apache.kafka.clients.consumer.internals.AbstractCoordinator
protected Map<String,ByteBuffer> performAssignment(String coordinationLeaderId, String protocol, List<org.apache.kafka.common.message.JoinGroupResponseData.JoinGroupResponseMember> allMemberMetadata)
performAssignment
in class org.apache.kafka.clients.consumer.internals.AbstractCoordinator
protected void onJoinComplete(int generation, String memberId, String protocol, 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