< Back
 

# Packages

-  package root
  Definition Classes
    root
-  package kafka
  Definition Classes
    root
-  package manager

  Definition Classes
    kafka
-  package utils

  Definition Classes
    manager
-  package one10
  Definition Classes
    utils
- BaseKey
- CommitRecordMetadataAndOffset
- Defaults
- GroupMetadata
- GroupMetadataKey
- GroupMetadataManager
- GroupOverview
- GroupTopicPartition
- LogConfig
- MemberMetadata
- OffsetKey

o

kafka.manager.utils.one10

# GroupMetadataManager 

###

#### object 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
 
Ordering

1. Alphabetic
2. By Inheritance

Inherited

1. GroupMetadataManager
2. AnyRef
3. Any

1. Hide All
2. Show All

Visibility

1. Public
2. All

### Type Members

1.  class GroupMetadataMessageFormatter extends MessageFormatter
2.  class OffsetsMessageFormatter extends MessageFormatter

### Value Members

1.  final def !=(arg0: Any): Boolean
   Definition Classes
     AnyRef → Any
2.  final def ##(): Int
   Definition Classes
     AnyRef → Any
3.  final def ==(arg0: Any): Boolean
   Definition Classes
     AnyRef → Any
4.  final def asInstanceOf[T0]: T0
   Definition Classes
     Any
5.  def clone(): AnyRef
   Attributes
     protected[java.lang]
   Definition Classes
     AnyRef
   Annotations
     @native() @throws( ... )
6.  final def eq(arg0: AnyRef): Boolean
   Definition Classes
     AnyRef
7.  def equals(arg0: Any): Boolean
   Definition Classes
     AnyRef → Any
8.  def finalize(): Unit
   Attributes
     protected[java.lang]
   Definition Classes
     AnyRef
   Annotations
     @throws( classOf[java.lang.Throwable] )
9.  final def getClass(): Class[_]
   Definition Classes
     AnyRef → Any
   Annotations
     @native()
10.  def hashCode(): Int
    Definition Classes
      AnyRef → Any
    Annotations
      @native()
11.  final def isInstanceOf[T0]: Boolean
    Definition Classes
      Any
12.  final def ne(arg0: AnyRef): Boolean
    Definition Classes
      AnyRef
13.  final def notify(): Unit
    Definition Classes
      AnyRef
    Annotations
      @native()
14.  final def notifyAll(): Unit
    Definition Classes
      AnyRef
    Annotations
      @native()
15.  def readGroupMessageValue(groupId: String, buffer: ByteBuffer, time: Time): GroupMetadata

    Decodes the group metadata messages' payload and retrieves its member metadata from it

    Decodes the group metadata messages' payload and retrieves its member metadata from it

    buffer

      input byte-buffer

    time

      the time instance to use

    returns

      a group metadata object from the message

16.  def readMessageKey(buffer: ByteBuffer): BaseKey

    Decodes the offset messages' key

    Decodes the offset messages' key

    buffer

      input byte-buffer

    returns

      an GroupTopicPartition object

17.  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

18.  final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
      AnyRef
19.  def toString(): String
    Definition Classes
      AnyRef → Any
20.  final def wait(): Unit
    Definition Classes
      AnyRef
    Annotations
      @throws( ... )
21.  final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
      AnyRef
    Annotations
      @throws( ... )
22.  final def wait(arg0: Long): Unit
    Definition Classes
      AnyRef
    Annotations
      @native() @throws( ... )

### Inherited from AnyRef

### Inherited from Any

### Ungrouped