GroupMetadataManager

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 addGroup(group: GroupMetadata): GroupMetadata

   

   Add a group or get the group associated with the given groupId if it already exists

5. def addPartitionOwnership(partition: Int): Unit

   

   Add the partition into the owned list

   Add the partition into the owned list

   NOTE: this is for test only

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. val config: OffsetConfig

   

10. def currentGroups(): Iterable[GroupMetadata]

    

11. def debug(msg: ⇒ String, e: ⇒ Throwable): Unit

    

    Definition Classes

    Logging

12. def debug(e: ⇒ Throwable): Any

    

    Definition Classes

    Logging

13. def debug(msg: ⇒ String): Unit

    

    Definition Classes

    Logging

14. final def eq(arg0: AnyRef): Boolean

    

    Definition Classes

    AnyRef

15. def equals(arg0: Any): Boolean

    

    Definition Classes

    AnyRef → Any

16. def error(msg: ⇒ String, e: ⇒ Throwable): Unit

    

    Definition Classes

    Logging

17. def error(e: ⇒ Throwable): Any

    

    Definition Classes

    Logging

18. def error(msg: ⇒ String): Unit

    

    Definition Classes

    Logging

19. def fatal(msg: ⇒ String, e: ⇒ Throwable): Unit

    

    Definition Classes

    Logging

20. def fatal(e: ⇒ Throwable): Any

    

    Definition Classes

    Logging

21. def fatal(msg: ⇒ String): Unit

    

    Definition Classes

    Logging

22. def finalize(): Unit

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

23. final def getClass(): Class[_]

    

    Definition Classes

    AnyRef → Any

24. def getGroup(groupId: String): GroupMetadata

    

    Get the group associated with the given groupId, or null if not found

25. def getOffsets(group: String, topicPartitions: Seq[TopicAndPartition]): Map[TopicAndPartition, OffsetMetadataAndError]

    

    The most important guarantee that this API provides is that it should never return a stale offset.

    The most important guarantee that this API provides is that it should never return a stale offset. i.e., it either returns the current offset or it begins to sync the cache from the log (and returns an error code).

26. def hashCode(): Int

    

    Definition Classes

    AnyRef → Any

27. def info(msg: ⇒ String, e: ⇒ Throwable): Unit

    

    Definition Classes

    Logging

28. def info(e: ⇒ Throwable): Any

    

    Definition Classes

    Logging

29. def info(msg: ⇒ String): Unit

    

    Definition Classes

    Logging

30. def isGroupLoading(groupId: String): Boolean

    

31. def isGroupLocal(groupId: String): Boolean

    

32. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

33. def isLoading(): Boolean

    

34. def loadGroupsForPartition(offsetsPartition: Int, onGroupLoaded: (GroupMetadata) ⇒ Unit): Unit

    

    Asynchronously read the partition from the offsets topic and populate the cache

35. var logIdent: String

    

    Attributes

    protected

    Definition Classes

    Logging

36. lazy val logger: Logger

    

    Definition Classes

    Logging

37. val loggerName: String

    

    Definition Classes

    Logging

38. final def ne(arg0: AnyRef): Boolean

    

    Definition Classes

    AnyRef

39. def newGauge[T](name: String, metric: Gauge[T], tags: Map[String, String] = Map.empty): Gauge[T]

    

    Definition Classes

    KafkaMetricsGroup

40. def newHistogram(name: String, biased: Boolean = true, tags: Map[String, String] = Map.empty): Histogram

    

    Definition Classes

    KafkaMetricsGroup

41. def newMeter(name: String, eventType: String, timeUnit: TimeUnit, tags: Map[String, String] = Map.empty): Meter

    

    Definition Classes

    KafkaMetricsGroup

42. def newTimer(name: String, durationUnit: TimeUnit, rateUnit: TimeUnit, tags: Map[String, String] = Map.empty): Timer

    

    Definition Classes

    KafkaMetricsGroup

43. final def notify(): Unit

    

    Definition Classes

    AnyRef

44. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

45. def partitionFor(groupId: String): Int

    

46. def prepareStoreGroup(group: GroupMetadata, groupAssignment: Map[String, Array[Byte]], responseCallback: (Short) ⇒ Unit): DelayedStore

    

47. def prepareStoreOffsets(groupId: String, consumerId: String, generationId: Int, offsetMetadata: Map[TopicAndPartition, OffsetAndMetadata], responseCallback: (Map[TopicAndPartition, Short]) ⇒ Unit): DelayedStore

    

    Store offsets by appending it to the replicated log and then inserting to cache

48. def removeGroup(group: GroupMetadata): Unit

    

    Remove all metadata associated with the group

49. def removeGroupsForPartition(offsetsPartition: Int, onGroupUnloaded: (GroupMetadata) ⇒ Unit): Unit

    

    When this broker becomes a follower for an offsets topic partition clear out the cache for groups that belong to that partition.

    When this broker becomes a follower for an offsets topic partition clear out the cache for groups that belong to that partition.

    offsetsPartition

    Groups belonging to this partition of the offsets topic will be deleted from the cache.

50. def removeMetric(name: String, tags: Map[String, String] = Map.empty): Unit

    

    Definition Classes

    KafkaMetricsGroup

51. def shutdown(): Unit

    

52. def store(delayedAppend: DelayedStore): Unit

    

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

55. def swallowError(action: ⇒ Unit): Unit

    

    Definition Classes

    Logging

56. def swallowInfo(action: ⇒ Unit): Unit

    

    Definition Classes

    Logging

57. def swallowTrace(action: ⇒ Unit): Unit

    

    Definition Classes

    Logging

58. def swallowWarn(action: ⇒ Unit): Unit

    

    Definition Classes

    Logging

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

    

    Definition Classes

    AnyRef

60. def toString(): String

    

    Definition Classes

    AnyRef → Any

61. def trace(msg: ⇒ String, e: ⇒ Throwable): Unit

    

    Definition Classes

    Logging

62. def trace(e: ⇒ Throwable): Any

    

    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

    @throws( ... )

67. def warn(msg: ⇒ String, e: ⇒ Throwable): Unit

    

    Definition Classes

    Logging

68. def warn(e: ⇒ Throwable): Any

    

    Definition Classes

    Logging

69. def warn(msg: ⇒ String): Unit

    

    Definition Classes

    Logging