< 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

c

kafka.manager.utils.one10

# GroupMetadata 

###
Companion object GroupMetadata

#### class GroupMetadata extends Logging

Group contains the following metadata:

Membership metadata:

1. Members registered in this group 2. Current protocol assigned to the group (e.g. partition assignment strategy for consumers) 3. Protocol metadata associated with group members

State metadata:

1. group state 2. generation id 3. leader id

Annotations
  @nonthreadsafe()

Linear Supertypes
Logging, AnyRef, Any
 
Ordering

1. Alphabetic
2. By Inheritance

Inherited

1. GroupMetadata
2. Logging
3. AnyRef
4. Any

1. Hide All
2. Show All

Visibility

1. Public
2. All

### Instance Constructors

1.  new GroupMetadata(groupId: String, initialState: GroupState, time: Time)

### Type Members

1.  type JoinCallback = (JoinGroupResult) ⇒ Unit

### 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.  def activeProducers: Set[Long]
5.  def add(member: MemberMetadata, callback: JoinCallback = null): Unit
6.  def allMemberMetadata: List[MemberMetadata]
7.  def allMembers: Set[String]
8.  def allOffsets: Map[TopicPartition, OffsetAndMetadata]
9.  final def asInstanceOf[T0]: T0
   Definition Classes
     Any
10.  def clone(): AnyRef
    Attributes
      protected[java.lang]
    Definition Classes
      AnyRef
    Annotations
      @native() @throws( ... )
11.  def completePendingTxnOffsetCommit(producerId: Long, isCommit: Boolean): Unit
12.  def currentState: GroupState
13.  var currentStateTimestamp: Option[Long]
14.  def currentStateTimestampOrDefault: Long
15.  def debug(msg: ⇒ String, e: ⇒ Throwable): Unit
    Definition Classes
      Logging
16.  def debug(msg: ⇒ String): Unit
    Definition Classes
      Logging
17.  final def eq(arg0: AnyRef): Boolean
    Definition Classes
      AnyRef
18.  def equals(arg0: Any): Boolean
    Definition Classes
      AnyRef → Any
19.  def error(msg: ⇒ String, e: ⇒ Throwable): Unit
    Definition Classes
      Logging
20.  def error(msg: ⇒ String): Unit
    Definition Classes
      Logging
21.  def failPendingTxnOffsetCommit(producerId: Long, topicPartition: TopicPartition): Unit
22.  def fatal(msg: ⇒ String, e: ⇒ Throwable): Unit
    Definition Classes
      Logging
23.  def fatal(msg: ⇒ String): Unit
    Definition Classes
      Logging
24.  def finalize(): Unit
    Attributes
      protected[java.lang]
    Definition Classes
      AnyRef
    Annotations
      @throws( classOf[java.lang.Throwable] )
25.  var generationId: Int
26.  def get(memberId: String): MemberMetadata
27.  final def getClass(): Class[_]
    Definition Classes
      AnyRef → Any
    Annotations
      @native()
28.  val groupId: String
29.  def has(memberId: String): Boolean
30.  def hasOffsets: Boolean
31.  def hasPendingOffsetCommitsFromProducer(producerId: Long): Boolean
32.  def hashCode(): Int
    Definition Classes
      AnyRef → Any
    Annotations
      @native()
33.  def inLock[T](fun: ⇒ T): T
34.  def info(msg: ⇒ String, e: ⇒ Throwable): Unit
    Definition Classes
      Logging
35.  def info(msg: ⇒ String): Unit
    Definition Classes
      Logging
36.  def is(groupState: GroupState): Boolean
37.  def isDebugEnabled: Boolean
    Definition Classes
      Logging
38.  final def isInstanceOf[T0]: Boolean
    Definition Classes
      Any
39.  def isLeader(memberId: String): Boolean
40.  def isTraceEnabled: Boolean
    Definition Classes
      Logging
41.  def leaderOrNull: String
42.  val logIdent: String
    Attributes
      protected
    Definition Classes
      Logging
43.  lazy val logger: Logger
    Attributes
      protected
    Definition Classes
      Logging
44.  def loggerName: String
    Attributes
      protected
    Definition Classes
      Logging
45.  def msgWithLogIdent(msg: String): String
    Attributes
      protected
    Definition Classes
      Logging
46.  final def ne(arg0: AnyRef): Boolean
    Definition Classes
      AnyRef
47.  var newMemberAdded: Boolean
48.  def not(groupState: GroupState): Boolean
49.  final def notify(): Unit
    Definition Classes
      AnyRef
    Annotations
      @native()
50.  final def notifyAll(): Unit
    Definition Classes
      AnyRef
    Annotations
      @native()
51.  def numOffsets: Int
52.  def offset(topicPartition: TopicPartition): Option[OffsetAndMetadata]
53.  def onTxnOffsetCommitAppend(producerId: Long, topicPartition: TopicPartition, commitRecordMetadataAndOffset: CommitRecordMetadataAndOffset): Unit
54.  def protocolOrNull: String
55.  var protocolType: Option[String]
56.  def removeAllOffsets(): Map[TopicPartition, OffsetAndMetadata]
57.  def removeExpiredOffsets(currentTimestamp: Long, offsetRetentionMs: Long): Map[TopicPartition, OffsetAndMetadata]
58.  def removeOffsets(topicPartitions: Seq[TopicPartition]): Map[TopicPartition, OffsetAndMetadata]
59.  def size: Int
60.  final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
      AnyRef
61.  def toString(): String
    Definition Classes
      GroupMetadata → AnyRef → Any
62.  def trace(msg: ⇒ String, e: ⇒ Throwable): Unit
    Definition Classes
      Logging
63.  def trace(msg: ⇒ String): Unit
    Definition Classes
      Logging
64.  final def wait(): Unit
    Definition Classes
      AnyRef
    Annotations
      @throws( ... )
65.  final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
      AnyRef
    Annotations
      @throws( ... )
66.  final def wait(arg0: Long): Unit
    Definition Classes
      AnyRef
    Annotations
      @native() @throws( ... )
67.  def warn(msg: ⇒ String, e: ⇒ Throwable): Unit
    Definition Classes
      Logging
68.  def warn(msg: ⇒ String): Unit
    Definition Classes
      Logging

### Inherited from Logging

### Inherited from AnyRef

### Inherited from Any

### Ungrouped