< 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
-  object GroupMetadataManager

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

  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]

  Definition Classes
    one10
- GroupMetadataMessageFormatter
- OffsetsMessageFormatter

c

kafka.manager.utils.one10.GroupMetadataManager

# GroupMetadataMessageFormatter 

###

#### class GroupMetadataMessageFormatter extends MessageFormatter

Linear Supertypes
MessageFormatter, AnyRef, Any
 
Ordering

1. Alphabetic
2. By Inheritance

Inherited

1. GroupMetadataMessageFormatter
2. MessageFormatter
3. AnyRef
4. Any

1. Hide All
2. Show All

Visibility

1. Public
2. All

### Instance Constructors

1.  new GroupMetadataMessageFormatter()

### 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.  def close(): Unit
   Definition Classes
     MessageFormatter
7.  final def eq(arg0: AnyRef): Boolean
   Definition Classes
     AnyRef
8.  def equals(arg0: Any): Boolean
   Definition Classes
     AnyRef → Any
9.  def finalize(): Unit
   Attributes
     protected[java.lang]
   Definition Classes
     AnyRef
   Annotations
     @throws( classOf[java.lang.Throwable] )
10.  final def getClass(): Class[_]
    Definition Classes
      AnyRef → Any
    Annotations
      @native()
11.  def hashCode(): Int
    Definition Classes
      AnyRef → Any
    Annotations
      @native()
12.  def init(props: Properties): Unit
    Definition Classes
      MessageFormatter
13.  final def isInstanceOf[T0]: Boolean
    Definition Classes
      Any
14.  final def ne(arg0: AnyRef): Boolean
    Definition Classes
      AnyRef
15.  final def notify(): Unit
    Definition Classes
      AnyRef
    Annotations
      @native()
16.  final def notifyAll(): Unit
    Definition Classes
      AnyRef
    Annotations
      @native()
17.  final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
      AnyRef
18.  def toString(): String
    Definition Classes
      AnyRef → Any
19.  final def wait(): Unit
    Definition Classes
      AnyRef
    Annotations
      @throws( ... )
20.  final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
      AnyRef
    Annotations
      @throws( ... )
21.  final def wait(arg0: Long): Unit
    Definition Classes
      AnyRef
    Annotations
      @native() @throws( ... )
22.  def writeTo(consumerRecord: ConsumerRecord[Array[Byte], Array[Byte]], output: PrintStream): Unit
    Definition Classes
      GroupMetadataMessageFormatter → MessageFormatter

### Inherited from MessageFormatter

### Inherited from AnyRef

### Inherited from Any

### Ungrouped