Sha256: 1d23635b0b120e5090e63401a885298014e88ec99804c8aa2b22700a1fb27a3a
Contents?: true
Size: 521 Bytes
Versions: 20
Compression:
Stored size: 521 Bytes
Contents
require 'zeebe/client'
zeebe_client = Zeebe::Client::GatewayProtocol::Gateway::Stub.new('localhost:26500', :this_channel_is_insecure)
topology = zeebe_client.topology(Zeebe::Client::GatewayProtocol::TopologyRequest.new)
puts "Zeebe topology:"
puts " Cluster size: #{topology.clusterSize}"
puts " Replication factor: #{topology.replicationFactor}"
puts " Brokers:"
topology.brokers.each do |b|
puts " - id: #{b.nodeId}, address: #{b.host}:#{b.port}, partitions: #{b.partitions.map { |p| p.partitionId }}"
end
Version data entries
20 entries across 20 versions & 1 rubygems