org.jumbune.remoting.common.ZKUtils.getActiveNameNode()方法的使用及代码示例

转载 作者：知者 更新时间：2024-03-13 09:32:43 27 4

/**
 * Gets the leader name node from zookeeper.
 * @param zkHosts 
 *
 * @return the leader name node from zookeeper
 */
public static byte[] getLeaderNameNodeFromZK(String[] zkHosts) {
  final int retryTimes = 10;
  byte[] nameHostName = null;
  int retryCount = 1;
  do {
    List<String> nameNodeNameList = getNodeChildrenList(zkHosts, ZKConstants.HADOOP_NODE_PATH);
    for (String nameNodeName : nameNodeNameList) {
      nameHostName = getActiveNameNode(zkHosts,
          ZKConstants.HADOOP_NODE_PATH + File.separator + nameNodeName + ZKConstants.ACTIVE_BREAD_CRUMB);
    }
    if (nameHostName == null) {
      try {
        LOGGER.warn("found active NN null from ZK, retrying after " + 100 * retryCount + " millisecs");
        Thread.sleep(100 * retryCount);
      } catch (InterruptedException e) {
      }
    }
    retryCount++;
  } while (nameHostName == null && retryCount <= retryTimes);
  return nameHostName;
}

/**
 * Gets the leader name node from zookeeper.
 * @param zkHosts 
 *
 * @return the leader name node from zookeeper
 */
public static byte[] getLeaderNameNodeFromZK(String[] zkHosts) {
  final int retryTimes = 10;
  byte[] nameHostName = null;
  int retryCount = 1;
  do {
    List<String> nameNodeNameList = getNodeChildrenList(zkHosts, ZKConstants.HADOOP_NODE_PATH);
    for (String nameNodeName : nameNodeNameList) {
      nameHostName = getActiveNameNode(zkHosts,
          ZKConstants.HADOOP_NODE_PATH + File.separator + nameNodeName + ZKConstants.ACTIVE_BREAD_CRUMB);
    }
    if (nameHostName == null) {
      try {
        LOGGER.warn("found active NN null from ZK, retrying after " + 100 * retryCount + " millisecs");
        Thread.sleep(100 * retryCount);
      } catch (InterruptedException e) {
      }
    }
    retryCount++;
  } while (nameHostName == null && retryCount <= retryTimes);
  return nameHostName;
}

27 4 0

• kafka.utils.ZkUtils.getReplicasForPartition()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.getReplicasForPartition()方法的一些代码示例，展示了ZkUtils.getReplicasForPartition(

• kafka.utils.ZkUtils.getConsumerGroups()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.getConsumerGroups()方法的一些代码示例，展示了ZkUtils.getConsumerGroups()的具体用法。这些代码示

• kafka.utils.ZkUtils.zkClient()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.zkClient()方法的一些代码示例，展示了ZkUtils.zkClient()的具体用法。这些代码示例主要来源于Github/Stack

• kafka.utils.ZkUtils.readDataMaybeNull()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.readDataMaybeNull()方法的一些代码示例，展示了ZkUtils.readDataMaybeNull()的具体用法。这些代码示

• kafka.utils.ZkUtils.updatePersistentPath()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.updatePersistentPath()方法的一些代码示例，展示了ZkUtils.updatePersistentPath()的具体用法

• kafka.utils.ZkUtils.getLeaderForPartition()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.getLeaderForPartition()方法的一些代码示例，展示了ZkUtils.getLeaderForPartition()的具体

• kafka.utils.ZkUtils.formatAsReassignmentJson()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.formatAsReassignmentJson()方法的一些代码示例，展示了ZkUtils.formatAsReassignmentJso

• kafka.utils.ZkUtils.getPartitionsForTopics()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.getPartitionsForTopics()方法的一些代码示例，展示了ZkUtils.getPartitionsForTopics()的

• kafka.utils.ZkUtils.createZkClientAndConnection()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.createZkClientAndConnection()方法的一些代码示例，展示了ZkUtils.createZkClientAndCon

• kafka.utils.ZkUtils.ConsumersPath()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.ConsumersPath()方法的一些代码示例，展示了ZkUtils.ConsumersPath()的具体用法。这些代码示例主要来源于Gi

• kafka.utils.ZkUtils.getPartitionsBeingReassigned()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.getPartitionsBeingReassigned()方法的一些代码示例，展示了ZkUtils.getPartitionsBeingR

• kafka.utils.ZkUtils.()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.()方法的一些代码示例，展示了ZkUtils.()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平

• kafka.utils.ZkUtils.apply()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.apply()方法的一些代码示例，展示了ZkUtils.apply()的具体用法。这些代码示例主要来源于Github/Stackoverfl

• kafka.utils.ZkUtils.BrokerIdsPath()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.BrokerIdsPath()方法的一些代码示例，展示了ZkUtils.BrokerIdsPath()的具体用法。这些代码示例主要来源于Gi

• kafka.utils.ZkUtils.getAllTopics()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.getAllTopics()方法的一些代码示例，展示了ZkUtils.getAllTopics()的具体用法。这些代码示例主要来源于Gith

• kafka.utils.ZkUtils.getAllBrokersInCluster()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.getAllBrokersInCluster()方法的一些代码示例，展示了ZkUtils.getAllBrokersInCluster()的

• kafka.utils.ZkUtils.getPartitionAssignmentForTopics()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.getPartitionAssignmentForTopics()方法的一些代码示例，展示了ZkUtils.getPartitionAssi

• kafka.utils.ZkUtils.close()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.close()方法的一些代码示例，展示了ZkUtils.close()的具体用法。这些代码示例主要来源于Github/Stackoverfl

• org.apache.zookeeper.ZKUtil.listSubTreeBFS()方法的使用及代码示例

  本文整理了Java中org.apache.zookeeper.ZKUtil.listSubTreeBFS()方法的一些代码示例，展示了ZKUtil.listSubTreeBFS()的具体用法。这些代码

• com.facebook.zookeeper.ZkUtil.bytesToString()方法的使用及代码示例

  本文整理了Java中com.facebook.zookeeper.ZkUtil.bytesToString()方法的一些代码示例，展示了ZkUtil.bytesToString()的具体用法。这些代码