kafka.coordinator

GroupCoordinator

class GroupCoordinator extends Logging

GroupCoordinator handles general group membership and offset management.

Each Kafka server instantiates a coordinator which is responsible for a set of groups. Groups are assigned to coordinators based on their group names.

Linear Supertypes
Logging, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. GroupCoordinator
  2. Logging
  3. AnyRef
  4. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new GroupCoordinator(brokerId: Int, groupConfig: GroupConfig, offsetConfig: OffsetConfig, replicaManager: ReplicaManager, zkUtils: ZkUtils)

  2. new GroupCoordinator(brokerId: Int, groupConfig: GroupConfig, offsetConfig: OffsetConfig, groupManager: GroupMetadataManager)

Type Members

  1. type JoinCallback = (JoinGroupResult) ⇒ Unit

  2. type SyncCallback = (Array[Byte], Short) ⇒ Unit

Value Members

  1. final def !=(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any
  3. final def ##(): Int

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

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

    Definition Classes
    Any
  6. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  7. val brokerId: Int

  8. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  9. def debug(msg: ⇒ String, e: ⇒ Throwable): Unit

    Definition Classes
    Logging
  10. def debug(e: ⇒ Throwable): Any

    Definition Classes
    Logging
  11. def debug(msg: ⇒ String): Unit

    Definition Classes
    Logging
  12. final def eq(arg0: AnyRef): Boolean

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

    Definition Classes
    AnyRef → Any
  14. def error(msg: ⇒ String, e: ⇒ Throwable): Unit

    Definition Classes
    Logging
  15. def error(e: ⇒ Throwable): Any

    Definition Classes
    Logging
  16. def error(msg: ⇒ String): Unit

    Definition Classes
    Logging
  17. def fatal(msg: ⇒ String, e: ⇒ Throwable): Unit

    Definition Classes
    Logging
  18. def fatal(e: ⇒ Throwable): Any

    Definition Classes
    Logging
  19. def fatal(msg: ⇒ String): Unit

    Definition Classes
    Logging
  20. def finalize(): Unit

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

    Definition Classes
    AnyRef → Any
  22. val groupConfig: GroupConfig

  23. val groupManager: GroupMetadataManager

  24. def handleCommitOffsets(groupId: String, memberId: String, generationId: Int, offsetMetadata: Map[TopicAndPartition, OffsetAndMetadata], responseCallback: (Map[TopicAndPartition, Short]) ⇒ Unit): Unit

  25. def handleDescribeGroup(groupId: String): (Errors, GroupSummary)

  26. def handleFetchOffsets(groupId: String, partitions: Seq[TopicAndPartition]): Map[TopicAndPartition, OffsetMetadataAndError]

  27. def handleGroupEmigration(offsetTopicPartitionId: Int): Unit

  28. def handleGroupImmigration(offsetTopicPartitionId: Int): Unit

  29. def handleHeartbeat(groupId: String, memberId: String, generationId: Int, responseCallback: (Short) ⇒ Unit): Unit

  30. def handleJoinGroup(groupId: String, memberId: String, clientId: String, clientHost: String, sessionTimeoutMs: Int, protocolType: String, protocols: List[(String, Array[Byte])], responseCallback: (JoinGroupResult) ⇒ Unit): Unit

  31. def handleLeaveGroup(groupId: String, consumerId: String, responseCallback: (Short) ⇒ Unit): Unit

  32. def handleListGroups(): (Errors, List[GroupOverview])

  33. def handleSyncGroup(groupId: String, generation: Int, memberId: String, groupAssignment: Map[String, Array[Byte]], responseCallback: (Array[Byte], Short) ⇒ Unit): Unit

  34. def hashCode(): Int

    Definition Classes
    AnyRef → Any
  35. def info(msg: ⇒ String, e: ⇒ Throwable): Unit

    Definition Classes
    Logging
  36. def info(e: ⇒ Throwable): Any

    Definition Classes
    Logging
  37. def info(msg: ⇒ String): Unit

    Definition Classes
    Logging
  38. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  39. var logIdent: String

    Attributes
    protected
    Definition Classes
    Logging
  40. lazy val logger: Logger

    Definition Classes
    Logging
  41. val loggerName: String

    Definition Classes
    Logging
  42. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  43. final def notify(): Unit

    Definition Classes
    AnyRef
  44. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  45. val offsetConfig: OffsetConfig

  46. def offsetsTopicConfigs: Properties

  47. def onCompleteHeartbeat(): Unit

  48. def onCompleteJoin(group: GroupMetadata): Unit

  49. def onExpireHeartbeat(group: GroupMetadata, member: MemberMetadata, heartbeatDeadline: Long): Unit

  50. def onExpireJoin(): Unit

  51. def partitionFor(group: String): Int

  52. def shutdown(): Unit

    Shutdown logic executed at the same time when server shuts down.

    Shutdown logic executed at the same time when server shuts down. Ordering of actions should be reversed from the startup process.

  53. def startup(): Unit

    Startup logic executed at the same time when the server starts up.

  54. def swallow(action: ⇒ Unit): Unit

    Definition Classes
    Logging
  55. def swallowDebug(action: ⇒ Unit): Unit

    Definition Classes
    Logging
  56. def swallowError(action: ⇒ Unit): Unit

    Definition Classes
    Logging
  57. def swallowInfo(action: ⇒ Unit): Unit

    Definition Classes
    Logging
  58. def swallowTrace(action: ⇒ Unit): Unit

    Definition Classes
    Logging
  59. def swallowWarn(action: ⇒ Unit): Unit

    Definition Classes
    Logging
  60. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  61. def toString(): String

    Definition Classes
    AnyRef → Any
  62. def trace(msg: ⇒ String, e: ⇒ Throwable): Unit

    Definition Classes
    Logging
  63. def trace(e: ⇒ Throwable): Any

    Definition Classes
    Logging
  64. def trace(msg: ⇒ String): Unit

    Definition Classes
    Logging
  65. def tryCompleteHeartbeat(group: GroupMetadata, member: MemberMetadata, heartbeatDeadline: Long, forceComplete: () ⇒ Boolean): Boolean

  66. def tryCompleteJoin(group: GroupMetadata, forceComplete: () ⇒ Boolean): Boolean

  67. final def wait(): Unit

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

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

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  70. def warn(msg: ⇒ String, e: ⇒ Throwable): Unit

    Definition Classes
    Logging
  71. def warn(e: ⇒ Throwable): Any

    Definition Classes
    Logging
  72. def warn(msg: ⇒ String): Unit

    Definition Classes
    Logging

Inherited from Logging

Inherited from AnyRef

Inherited from Any

Ungrouped