GroupCoordinator

GroupCoordinator is…​FIXME

GroupCoordinator is created when…​FIXME

GroupCoordinator startup.png
Figure 1. GroupCoordinator’s Startup

logIdent is [GroupCoordinator [brokerId]].

GroupCoordinator uses isActive flag to…​FIXME

Creating GroupCoordinator Instance — apply Factory Method

apply(
  config: KafkaConfig,
  zkClient: KafkaZkClient,
  replicaManager: ReplicaManager,
  time: Time): GroupCoordinator
apply(
  config: KafkaConfig,
  zkClient: KafkaZkClient,
  replicaManager: ReplicaManager,
  heartbeatPurgatory: DelayedOperationPurgatory[DelayedHeartbeat],
  joinPurgatory: DelayedOperationPurgatory[DelayedJoin],
  time: Time): GroupCoordinator

apply…​FIXME

Note
apply is used exclusively when KafkaServer is requested to start up.

Creating GroupCoordinator Instance

GroupCoordinator takes the following when created:

GroupCoordinator initializes the internal registries and counters.

Starting Up (and GroupMetadataManager) — startup Method

startup(enableMetadataExpiration: Boolean = true): Unit

startup first prints out the following INFO message to the logs:

INFO [GroupCoordinator [brokerId]]: Starting up. (kafka.coordinator.group.GroupCoordinator)

With enableMetadataExpiration input flag enabled, startup requests GroupMetadataManager to enableMetadataExpiration.

startup turns isActive flag on.

In the end, startup prints out the following INFO message to the logs:

INFO [GroupCoordinator [brokerId]]: Startup complete. (kafka.coordinator.group.GroupCoordinator)
Note
startup is used exclusively when KafkaServer starts up.

partitionFor Method

partitionFor(group: String): Int

partitionFor simply requests the GroupMetadataManager to partitionFor the input group ID.

Note
partitionFor is used when…​FIXME

handleCommitOffsets Method

handleCommitOffsets(
  groupId: String,
  memberId: String,
  generationId: Int,
  offsetMetadata: immutable.Map[TopicPartition, OffsetAndMetadata],
  responseCallback: immutable.Map[TopicPartition, Errors] => Unit): Unit

handleCommitOffsets…​FIXME

Note
handleCommitOffsets is used exclusively when KafkaApis is requested to handleOffsetCommitRequest.

doCommitOffsets Internal Method

doCommitOffsets(
  group: GroupMetadata,
  memberId: String,
  generationId: Int,
  producerId: Long,
  producerEpoch: Short,
  offsetMetadata: immutable.Map[TopicPartition, OffsetAndMetadata],
  responseCallback: immutable.Map[TopicPartition, Errors] => Unit): Unit

doCommitOffsets…​FIXME

Note
doCommitOffsets is used when GroupCoordinator is requested to handleTxnCommitOffsets and handleCommitOffsets.

onCompleteJoin Method

onCompleteJoin(group: GroupMetadata): Unit

onCompleteJoin…​FIXME

Note
onCompleteJoin is used when…​FIXME

doSyncGroup Internal Method

doSyncGroup(
  group: GroupMetadata,
  generationId: Int,
  memberId: String,
  groupAssignment: Map[String, Array[Byte]],
  responseCallback: SyncCallback): Unit

doSyncGroup…​FIXME

Note
doSyncGroup is used when…​FIXME

handleDescribeGroup Method

handleDescribeGroup(groupId: String): (Errors, GroupSummary)

handleDescribeGroup…​FIXME

Note
handleDescribeGroup is used exclusively when KafkaApis is requested to handleDescribeGroupRequest.

results matching ""

    No results matching ""