Partition

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 addReplicaIfNotExists(replica: Replica): Replica

   

5. def appendMessagesToLeader(messages: ByteBufferMessageSet, requiredAcks: Int = 0): LogAppendInfo

   

6. final def asInstanceOf[T0]: T0

   

   Definition Classes

   Any

7. def assignedReplicas(): Set[Replica]

   

8. def checkEnoughReplicasReachOffset(requiredOffset: Long): (Boolean, Short)

   

9. def clone(): AnyRef

   

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... )

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

13. def delete(): Unit

    

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

    

    Definition Classes

    AnyRef

15. def equals(that: Any): Boolean

    

    Definition Classes

    Partition → 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 getLeaderEpoch(): Int

    

25. def getOrCreateReplica(replicaId: Int = localBrokerId): Replica

    

26. def getOutOfSyncReplicas(leaderReplica: Replica, maxLagMs: Long): Set[Replica]

    

27. def getReplica(replicaId: Int = localBrokerId): Option[Replica]

    

28. def hashCode(): Int

    

    Definition Classes

    Partition → AnyRef → Any

29. var inSyncReplicas: Set[Replica]

    

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

33. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

34. def isUnderReplicated(): Boolean

    

35. var leaderReplicaIdOpt: Option[Int]

    

36. def leaderReplicaIfLocal(): Option[Replica]

    

37. var logIdent: String

    

    Attributes

    protected

    Definition Classes

    Logging

38. lazy val logger: Logger

    

    Definition Classes

    Logging

39. val loggerName: String

    

    Definition Classes

    Logging

40. def makeFollower(controllerId: Int, partitionStateInfo: PartitionStateInfo, correlationId: Int): Boolean

    

    Make the local replica the follower by setting the new leader and ISR to empty If the leader replica id does not change, return false to indicate the replica manager

41. def makeLeader(controllerId: Int, partitionStateInfo: PartitionStateInfo, correlationId: Int): Boolean

    

    Make the local replica the leader by resetting LogEndOffset for remote replicas (there could be old LogEndOffset from the time when this broker was the leader last time) and setting the new leader and ISR.

    Make the local replica the leader by resetting LogEndOffset for remote replicas (there could be old LogEndOffset from the time when this broker was the leader last time) and setting the new leader and ISR. If the leader replica id does not change, return false to indicate the replica manager.

42. def maybeExpandIsr(replicaId: Int): Unit

    

    Check and maybe expand the ISR of the partition.

    Check and maybe expand the ISR of the partition.

    This function can be triggered when a replica's LEO has incremented

43. def maybeShrinkIsr(replicaMaxLagTimeMs: Long): Unit

    

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

    

    Definition Classes

    AnyRef

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

    

    Definition Classes

    KafkaMetricsGroup

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

    

    Definition Classes

    KafkaMetricsGroup

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

    

    Definition Classes

    KafkaMetricsGroup

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

    

    Definition Classes

    KafkaMetricsGroup

49. final def notify(): Unit

    

    Definition Classes

    AnyRef

50. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

51. val partitionId: Int

    

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

    

    Definition Classes

    KafkaMetricsGroup

53. def removeReplica(replicaId: Int): Unit

    

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. val tags: Map[String, String]

    

62. def toString(): String

    

    Definition Classes

    Partition → AnyRef → Any

63. val topic: String

    

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

66. def trace(msg: ⇒ String): Unit

    

    Definition Classes

    Logging

67. def updateReplicaLogReadResult(replicaId: Int, logReadResult: LogReadResult): Unit

    

    Update the log end offset of a certain replica of this partition

68. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

69. final def wait(arg0: Long, arg1: Int): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

70. final def wait(arg0: Long): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging