ReplicaManager

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 becomeLeaderOrFollower(leaderAndISRRequest: LeaderAndIsrRequest, offsetManager: OffsetManager): (Map[(String, Int), Short], Short)

   

6. def checkpointHighWatermarks(): Unit

   

   Flushes the highwatermark value for all partitions to the highwatermark file

7. def clone(): AnyRef

   

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... )

8. val config: KafkaConfig

   

9. var controllerEpoch: Int

   

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. final def eq(arg0: AnyRef): Boolean

    

    Definition Classes

    AnyRef

14. def equals(arg0: Any): Boolean

    

    Definition Classes

    AnyRef → Any

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

21. var fetchRequestPurgatory: FetchRequestPurgatory

    

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 getLeaderReplicaIfLocal(topic: String, partitionId: Int): Replica

    

25. def getOrCreatePartition(topic: String, partitionId: Int): Partition

    

26. def getPartition(topic: String, partitionId: Int): Option[Partition]

    

27. def getReplica(topic: String, partitionId: Int, replicaId: Int = config.brokerId): Option[Replica]

    

28. def getReplicaOrException(topic: String, partition: Int): Replica

    

29. def hashCode(): Int

    

    Definition Classes

    AnyRef → Any

30. val highWatermarkCheckpoints: Map[String, OffsetCheckpoint]

    

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

34. def initWithRequestPurgatory(producerRequestPurgatory: ProducerRequestPurgatory, fetchRequestPurgatory: FetchRequestPurgatory): Unit

    

    Initialize the replica manager with the request purgatory

    Initialize the replica manager with the request purgatory

    TODO: will be removed in 0.9 where we refactor server structure

35. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

36. val isShuttingDown: AtomicBoolean

    

37. val isrExpandRate: Meter

    

38. val isrShrinkRate: Meter

    

39. var logIdent: String

    

    Attributes

    protected

    Definition Classes

    Logging

40. val logManager: LogManager

    

41. lazy val logger: Logger

    

    Definition Classes

    Logging

42. val loggerName: String

    

    Definition Classes

    Logging

43. def maybeUpdateMetadataCache(updateMetadataRequest: UpdateMetadataRequest, metadataCache: MetadataCache): Unit

    

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

    

    Definition Classes

    AnyRef

45. def newGauge[T](name: String, metric: Gauge[T]): Gauge[T]

    

    Definition Classes

    KafkaMetricsGroup

46. def newHistogram(name: String, biased: Boolean = true): Histogram

    

    Definition Classes

    KafkaMetricsGroup

47. def newMeter(name: String, eventType: String, timeUnit: TimeUnit): Meter

    

    Definition Classes

    KafkaMetricsGroup

48. def newTimer(name: String, durationUnit: TimeUnit, rateUnit: TimeUnit): Timer

    

    Definition Classes

    KafkaMetricsGroup

49. final def notify(): Unit

    

    Definition Classes

    AnyRef

50. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

51. var producerRequestPurgatory: ProducerRequestPurgatory

    

52. def readMessageSets(fetchRequest: FetchRequest): Map[TopicAndPartition, PartitionDataAndOffset]

    

    Read from all the offset details given and return a map of (topic, partition) -> PartitionData

53. def removeMetric(name: String): Unit

    

    Definition Classes

    KafkaMetricsGroup

54. val replicaFetcherManager: ReplicaFetcherManager

    

55. def shutdown(): Unit

    

56. def startHighWaterMarksCheckPointThread(): Unit

    

57. def startup(): Unit

    

58. val stateChangeLogger: StateChangeLogger

    

59. def stopReplica(topic: String, partitionId: Int, deletePartition: Boolean): Short

    

60. def stopReplicas(stopReplicaRequest: StopReplicaRequest): (Map[TopicAndPartition, Short], Short)

    

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    AnyRef

68. def toString(): String

    

    Definition Classes

    AnyRef → Any

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

72. def unblockDelayedFetchRequests(key: DelayedRequestKey): Unit

    

    Unblock some delayed fetch requests with the request key

73. def unblockDelayedProduceRequests(key: DelayedRequestKey): Unit

    

    Unblock some delayed produce requests with the request key

74. def underReplicatedPartitionCount(): Int

    

75. def updateReplicaLEOAndPartitionHW(topic: String, partitionId: Int, replicaId: Int, offset: LogOffsetMetadata): Unit

    

76. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

82. val zkClient: ZkClient