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

Broker.getNode介绍

暂无

代码示例

代码示例来源：origin: allegro/hermes

@Override
@SuppressWarnings("unchecked")
public BrokerDetails readBrokerDetails(Integer brokerId) {
  try {
    Broker broker = kafkaZkClient.getBroker(brokerId).get();
    String host = broker.getNode(ListenerName.normalised(BROKER_LISTENER_NAME)).get().host();
    int port = broker.getNode(ListenerName.normalised(BROKER_LISTENER_NAME)).get().port();
    return new BrokerDetails(host, port);
  } catch (Exception exception) {
    throw new BrokerInfoNotAvailableException(brokerId, exception);
  }
}

代码示例来源：origin: vakinge/jeesuite-libs

public List<BrokerInfo> fetchAllBrokers(){
  List<BrokerInfo> result = new ArrayList<>();
  Seq<Broker> brokers = zkUtils.getAllBrokersInCluster();
  Iterator<Broker> iterator = brokers.toList().iterator();
  while(iterator.hasNext()){
    Broker broker = iterator.next();
    Node node = broker.getNode(ListenerName.forSecurityProtocol(SecurityProtocol.PLAINTEXT)).get();
    result.add(new BrokerInfo(node.idString(), node.host(), node.port()));
  }
  return result;
}