package
coordinator
Type Members
-
trait
BaseKey extends AnyRef
-
-
case class
GroupConfig(groupMinSessionTimeoutMs: Int, groupMaxSessionTimeoutMs: Int) extends Product with Serializable
-
-
case class
GroupMetadataKey(version: Short, key: String) extends BaseKey with Product with Serializable
-
-
case class
GroupOverview(groupId: String, protocolType: String) extends Product with Serializable
-
case class
GroupSummary(state: String, protocolType: String, protocol: String, members: List[MemberSummary]) extends Product with Serializable
-
case class
GroupTopicPartition(group: String, topicPartition: TopicAndPartition) extends Product with Serializable
-
case class
JoinGroupResult(members: Map[String, Array[Byte]], memberId: String, generationId: Int, subProtocol: String, leaderId: String, errorCode: Short) extends Product with Serializable
-
case class
MemberSummary(memberId: String, clientId: String, clientHost: String, metadata: Array[Byte], assignment: Array[Byte]) extends Product with Serializable
-
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
-
case class
OffsetKey(version: Short, key: GroupTopicPartition) extends BaseKey with Product with Serializable