kafka

coordinator

package coordinator

Visibility
  1. Public
  2. All

Type Members

  1. trait BaseKey extends AnyRef

  2. case class DelayedStore(messageSet: Map[TopicAndPartition, MessageSet], callback: (Map[TopicAndPartition, ProducerResponseStatus]) ⇒ Unit) extends Product with Serializable

  3. case class GroupConfig(groupMinSessionTimeoutMs: Int, groupMaxSessionTimeoutMs: Int) extends Product with Serializable

  4. class GroupCoordinator extends Logging

    GroupCoordinator handles general group membership and offset management.

  5. case class GroupMetadataKey(version: Short, key: String) extends BaseKey with Product with Serializable

  6. class GroupMetadataManager extends Logging with KafkaMetricsGroup

  7. case class GroupOverview(groupId: String, protocolType: String) extends Product with Serializable

    Case class used to represent group metadata for the ListGroups API

  8. case class GroupSummary(state: String, protocolType: String, protocol: String, members: List[MemberSummary]) extends Product with Serializable

    Case class used to represent group metadata for the DescribeGroup API

  9. case class GroupTopicPartition(group: String, topicPartition: TopicAndPartition) extends Product with Serializable

  10. case class JoinGroupResult(members: Map[String, Array[Byte]], memberId: String, generationId: Int, subProtocol: String, leaderId: String, errorCode: Short) extends Product with Serializable

  11. case class MemberSummary(memberId: String, clientId: String, clientHost: String, metadata: Array[Byte], assignment: Array[Byte]) extends Product with Serializable

  12. case class OffsetConfig(maxMetadataSize: Int = OffsetConfig.DefaultMaxMetadataSize, loadBufferSize: Int = OffsetConfig.DefaultLoadBufferSize, offsetsRetentionMs: Long = ..., offsetsRetentionCheckIntervalMs: Long = ..., offsetsTopicNumPartitions: Int = ..., offsetsTopicSegmentBytes: Int = ..., offsetsTopicReplicationFactor: Short = ..., offsetsTopicCompressionCodec: CompressionCodec = ..., offsetCommitTimeoutMs: Int = ..., offsetCommitRequiredAcks: Short = ...) extends Product with Serializable

    Configuration settings for in-built offset management

  13. case class OffsetKey(version: Short, key: GroupTopicPartition) extends BaseKey with Product with Serializable

Value Members

  1. object GroupCoordinator

  2. object GroupMetadataManager

    Messages stored for the group topic has versions for both the key and value fields.

  3. object OffsetConfig extends Serializable

Ungrouped