KafkaZkClient

KafkaZkClient is…​FIXME

KafkaZkClient is a KafkaMetricsGroup that…​FIXME

KafkaZkClient is created (using the apply factory method) when…​FIXME

getTopicPartitionCount Method

getTopicPartitionCount(topic: String): Option[Int]

getTopicPartitionCount…​FIXME

Note
getTopicPartitionCount is used when…​FIXME

Registering StateChangeHandler — registerStateChangeHandler Method

registerStateChangeHandler(stateChangeHandler: StateChangeHandler): Unit

registerStateChangeHandler…​FIXME

Note
registerStateChangeHandler is used when…​FIXME

Creating KafkaZkClient Instance

KafkaZkClient takes the following when created:

KafkaZkClient initializes the internal registries and counters.

Creating KafkaZkClient Instance — apply Factory Method

apply(
  connectString: String,
  isSecure: Boolean,
  sessionTimeoutMs: Int,
  connectionTimeoutMs: Int,
  maxInFlightRequests: Int,
  time: Time,
  metricGroup: String = "kafka.server",
  metricType: String = "SessionExpireListener"): KafkaZkClient

apply…​FIXME

Note

apply is used when:

  • KafkaServer is requested to initZkClient

  • AclCommand (when SimpleAclAuthorizer is used and requested to configure), ConfigCommand, PreferredReplicaLeaderElectionCommand, ReassignPartitionsCommand and TopicCommand commands are executed (main)

createTopLevelPaths Method

createTopLevelPaths(): Unit

createTopLevelPaths…​FIXME

Note
createTopLevelPaths is used when…​FIXME

updateBrokerInfoInZk Method

updateBrokerInfoInZk(brokerInfo: BrokerInfo): Unit

updateBrokerInfoInZk…​FIXME

Note
updateBrokerInfoInZk is used when…​FIXME

registerZNodeChildChangeHandler Method

registerZNodeChildChangeHandler(zNodeChildChangeHandler: ZNodeChildChangeHandler): Unit

registerZNodeChildChangeHandler…​FIXME

Note
registerZNodeChildChangeHandler is used when…​FIXME

registerZNodeChangeHandlerAndCheckExistence Method

registerZNodeChangeHandlerAndCheckExistence(zNodeChangeHandler: ZNodeChangeHandler): Boolean

registerZNodeChangeHandlerAndCheckExistence…​FIXME

Note
registerZNodeChangeHandlerAndCheckExistence is used when…​FIXME

deleteLogDirEventNotifications Method

deleteLogDirEventNotifications(): Unit

deleteLogDirEventNotifications…​FIXME

Note
deleteLogDirEventNotifications is used when…​FIXME

deleteIsrChangeNotifications Method

deleteIsrChangeNotifications(): Unit

deleteIsrChangeNotifications…​FIXME

Note
deleteIsrChangeNotifications is used when…​FIXME

unregisterZNodeChildChangeHandler Method

unregisterZNodeChildChangeHandler(path: String): Unit

unregisterZNodeChildChangeHandler…​FIXME

Note
unregisterZNodeChildChangeHandler is used when…​FIXME

unregisterZNodeChangeHandler Method

unregisterZNodeChangeHandler(path: String): Unit

unregisterZNodeChangeHandler…​FIXME

Note
unregisterZNodeChangeHandler is used when…​FIXME

setControllerEpochRaw Method

setControllerEpochRaw(epoch: Int, epochZkVersion: Int): SetDataResponse

setControllerEpochRaw…​FIXME

Note
setControllerEpochRaw is used when…​FIXME

createControllerEpochRaw Method

createControllerEpochRaw(epoch: Int): CreateResponse

createControllerEpochRaw…​FIXME

Note
createControllerEpochRaw is used when…​FIXME

getAllBrokersInCluster Method

getAllBrokersInCluster: Seq[Broker]

getAllBrokersInCluster…​FIXME

Note
getAllBrokersInCluster is used when…​FIXME

getAllTopicsInCluster Method

getAllTopicsInCluster: Seq[String]

getAllTopicsInCluster…​FIXME

Note
getAllTopicsInCluster is used when…​FIXME

getReplicaAssignmentForTopics Method

getReplicaAssignmentForTopics(topics: Set[String]): Map[TopicPartition, Seq[Int]]

getReplicaAssignmentForTopics…​FIXME

Note
getReplicaAssignmentForTopics is used when…​FIXME

getPartitionReassignment Method

getPartitionReassignment: collection.Map[TopicPartition, Seq[Int]]

getPartitionReassignment…​FIXME

Note
getPartitionReassignment is used when…​FIXME

getTopicDeletions Method

getTopicDeletions: Seq[String]

getTopicDeletions…​FIXME

Note
getTopicDeletions is used when…​FIXME

getTopicPartitionStates Method

getTopicPartitionStates(partitions: Seq[TopicPartition]): Map[TopicPartition, LeaderIsrAndControllerEpoch]

getTopicPartitionStates…​FIXME

Note
getTopicPartitionStates is used when…​FIXME

registerZNodeChangeHandler Method

registerZNodeChangeHandler(zNodeChangeHandler: ZNodeChangeHandler): Unit

registerZNodeChangeHandler…​FIXME

Note
registerZNodeChangeHandler is used when…​FIXME

getControllerEpoch Method

getControllerEpoch: Option[(Int, Stat)]

getControllerEpoch…​FIXME

Note
getControllerEpoch is used when…​FIXME

deletePartitionReassignment Method

deletePartitionReassignment(): Unit

deletePartitionReassignment…​FIXME

Note
deletePartitionReassignment is used when…​FIXME

setOrCreatePartitionReassignment Method

setOrCreatePartitionReassignment(reassignment: collection.Map[TopicPartition, Seq[Int]]): Unit

setOrCreatePartitionReassignment…​FIXME

Note
setOrCreatePartitionReassignment is used when…​FIXME

Getting Active Controller ID — getControllerId Method

getControllerId: Option[Int]

getControllerId sends a request to Zookeeper for the data of the /controller znode and returns the following:

  • The brokerid field of the JSON data when the response is OK

  • None for a NONODE response

  • Throws a KeeperException with the response code and the /controller path

Note

getControllerId is used when:

Creating Ephemeral Znode (And Throwing Exception When Unsuccessful)-- checkedEphemeralCreate Method

checkedEphemeralCreate(path: String, data: Array[Byte]): Unit

checkedEphemeralCreate…​FIXME

Note
checkedEphemeralCreate is used when…​FIXME

results matching ""

    No results matching ""