个人中心
gpt4 book ai didi

io.zeebe.client.ZeebeClient.newTopologyRequest()方法的使用及代码示例

转载 作者：知者 更新时间：2024-03-18 00:21:31 27 4
gpt4 key购买 nike

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

ZeebeClient.newTopologyRequest介绍

[英]Request the current cluster topology. Can be used to inspect which brokers are available at which endpoint and which broker is the leader of which partition.

List<BrokerInfo> brokers = zeebeClient 
.newTopologyRequest() 
.send() 
.join() 
.getBrokers(); 
SocketAddress address = broker.getSocketAddress(); 
List<PartitionInfo> partitions = broker.getPartitions();

[中]请求当前群集拓扑。可用于检查哪些代理在哪个端点可用，以及哪个代理是哪个分区的负责人

List<BrokerInfo> brokers = zeebeClient 
.newTopologyRequest() 
.send() 
.join() 
.getBrokers(); 
SocketAddress address = broker.getSocketAddress(); 
List<PartitionInfo> partitions = broker.getPartitions();

代码示例

代码示例来源：origin: zeebe-io/zeebe

public static void main(final String[] args) {
  final String broker = "127.0.0.1:26500";

  final ZeebeClientBuilder builder = ZeebeClient.newClientBuilder().brokerContactPoint(broker);

  try (ZeebeClient client = builder.build()) {
   System.out.println("Requesting topology with initial contact point " + broker);

   final Topology topology = client.newTopologyRequest().send().join();

   System.out.println("Topology:");
   topology
     .getBrokers()
     .forEach(
       b -> {
        System.out.println("    " + b.getAddress());
        b.getPartitions()
          .forEach(
            p ->
              System.out.println(
                "      " + p.getPartitionId() + " - " + p.getRole()));
       });

   System.out.println("Done.");
  }
 }
}

代码示例来源：origin: io.zeebe/zeebe-test

private void determineDefaultPartition() {
 final Topology topology = client.newTopologyRequest().send().join();
 defaultPartition = -1;
 final List<BrokerInfo> topologyBrokers = topology.getBrokers();
 for (final BrokerInfo leader : topologyBrokers) {
  final List<PartitionInfo> partitions = leader.getPartitions();
  for (final PartitionInfo brokerPartitionState : partitions) {
   if (brokerPartitionState.isLeader()) {
    defaultPartition = brokerPartitionState.getPartitionId();
    break;
   }
  }
 }
 if (defaultPartition < 0) {
  throw new RuntimeException("Could not detect leader for default partition");
 }
}

代码示例来源：origin: zeebe-io/zeebe

private void determineDefaultPartition() {
 final Topology topology = client.newTopologyRequest().send().join();
 defaultPartition = -1;
 final List<BrokerInfo> topologyBrokers = topology.getBrokers();
 for (final BrokerInfo leader : topologyBrokers) {
  final List<PartitionInfo> partitions = leader.getPartitions();
  for (final PartitionInfo brokerPartitionState : partitions) {
   if (brokerPartitionState.isLeader()) {
    defaultPartition = brokerPartitionState.getPartitionId();
    break;
   }
  }
 }
 if (defaultPartition < 0) {
  throw new RuntimeException("Could not detect leader for default partition");
 }
}

27 4 0
文章推荐： io.zeebe.client.ZeebeClient.newClientBuilder()方法的使用及代码示例
文章推荐： com.bugvm.sound.YNative.stop()方法的使用及代码示例
文章推荐： com.bugvm.sound.YNative.Terminate()方法的使用及代码示例
文章推荐： com.bugvm.sound.YSourceDataLine.open()方法的使用及代码示例
知者
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
全站热门文章
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com