GroupMetadataManager

Messages stored for the group topic has versions for both the key and value fields. Key version is used to indicate the type of the message (also to differentiate different types of messages from being compacted together if they have the same field values); and value version is used to evolve the messages within their data types:

key version 0: group consumption offset -> value version 0: [offset, metadata, timestamp]

key version 1: group consumption offset -> value version 1: [offset, metadata, commit_timestamp, expire_timestamp]

key version 2: group metadata -> value version 0: [protocol_type, generation, protocol, leader, members]

Linear Supertypes

AnyRef, Any

Type Members

class GroupMetadataMessageFormatter extends MessageFormatter
class OffsetsMessageFormatter extends MessageFormatter

Value Members

final def !=(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def ##(): Int

Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def asInstanceOf[T0]: T0

Definition Classes
Any
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def equals(arg0: Any): Boolean

Definition Classes
AnyRef → Any
def finalize(): Unit

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
def groupMetadataKey(group: String): Array[Byte]

Generates the key for group metadata message for given group
Generates the key for group metadata message for given group
returns
key bytes for group metadata message
def hashCode(): Int

Definition Classes
AnyRef → Any
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
def offsetCommitKey(group: String, topicPartition: TopicPartition, versionId: Short = 0): Array[Byte]

Generates the key for offset commit message for given (group, topic, partition)
Generates the key for offset commit message for given (group, topic, partition)
returns
key for offset commit message
def offsetCommitValue(offsetAndMetadata: OffsetAndMetadata): Array[Byte]

Generates the payload for offset commit message from given offset and metadata
Generates the payload for offset commit message from given offset and metadata
offsetAndMetadata
consumer's current offset and metadata
returns
payload for offset commit message
def readGroupMessageValue(groupId: String, buffer: ByteBuffer): GroupMetadata

Decodes the group metadata messages' payload and retrieves its member metadatafrom it
Decodes the group metadata messages' payload and retrieves its member metadatafrom it
buffer
input byte-buffer
returns
a group metadata object from the message
def readMessageKey(buffer: ByteBuffer): BaseKey

Decodes the offset messages' key
Decodes the offset messages' key
buffer
input byte-buffer
returns
an GroupTopicPartition object
def readOffsetMessageValue(buffer: ByteBuffer): OffsetAndMetadata

Decodes the offset messages' payload and retrieves offset and metadata from it
Decodes the offset messages' payload and retrieves offset and metadata from it
buffer
input byte-buffer
returns
an offset-metadata object from the message
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
def toString(): String

Definition Classes
AnyRef → Any
final def wait(): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long, arg1: Int): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )

Related Doc: package one10

object GroupMetadataManager

Type Members

class GroupMetadataMessageFormatter extends MessageFormatter

class OffsetsMessageFormatter extends MessageFormatter

Value Members

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

final def asInstanceOf[T0]: T0

def clone(): AnyRef

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def finalize(): Unit

final def getClass(): Class[_]

def groupMetadataKey(group: String): Array[Byte]

def hashCode(): Int

final def isInstanceOf[T0]: Boolean

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

def offsetCommitKey(group: String, topicPartition: TopicPartition, versionId: Short = 0): Array[Byte]

def offsetCommitValue(offsetAndMetadata: OffsetAndMetadata): Array[Byte]

def readGroupMessageValue(groupId: String, buffer: ByteBuffer): GroupMetadata

def readMessageKey(buffer: ByteBuffer): BaseKey

def readOffsetMessageValue(buffer: ByteBuffer): OffsetAndMetadata

final def synchronized[T0](arg0: ⇒ T0): T0

def toString(): String

final def wait(): Unit

final def wait(arg0: Long, arg1: Int): Unit

final def wait(arg0: Long): Unit

Inherited from AnyRef

Inherited from Any

Ungrouped