本文整理了Java中kafka.utils.ZkUtils.readDataMaybeNull()方法的一些代码示例，展示了ZkUtils.readDataMaybeNull()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZkUtils.readDataMaybeNull()方法的具体详情如下：
包路径：kafka.utils.ZkUtils
类名称：ZkUtils
方法名：readDataMaybeNull

ZkUtils.readDataMaybeNull介绍

暂无

代码示例

代码示例来源：origin: com.hurence.logisland/logisland-agent

private SimpleConsumer getZkConsumer(int brokerId) {
  try {
    Option<String> data = zkUtils.readDataMaybeNull(ZkUtils.BrokerIdsPath() + "/" + brokerId)._1;
    Map<String, Object> brokerInfo = (Map<String, Object>) JSON.parseFull(data.get()).get();
    String host = (String) brokerInfo.get("host");
    int port = (int) brokerInfo.get("port");
    return new SimpleConsumer(host, port, 10000, 100000, "ConsumerGroupCommand");
  } catch (Exception ex) {
    System.out.println("Could not parse broker info due to " + ex.getMessage());
    return null;
  }
}

代码示例来源：origin: gnuhpc/Kafka-zk-restapi

tp -> {
 Option<String> owner =
   zkUtils.readDataMaybeNull(
       groupDirs.consumerOwnerDir() + "/" + tp.partition())
     ._1;