Sha256: 0487c96ec7e9c5e35cb150cdf5edf0980caa87ebfb6357000fdef62a14f91499
Contents?: true
Size: 801 Bytes
Versions: 5
Compression:
Stored size: 801 Bytes
Contents
<% process.consumer_groups.each do |consumer_group| %>
<% sg_topics = Hash.new { |h, k| h[k] = [] } %>
<% consumer_group.subscription_groups.each do |subscription_group| %>
<% subscription_group.topics.each do |topic| %>
<% sg_topics[topic.name] += topic.partitions.map(&:id) %>
<% end %>
<% end %>
<% sg_topics.each do |topic_name, partitions| %>
<% partitions_list = partitions.join(', ') %>
<span
class="badge bg-secondary badge-topic"
title="Consumer group: <%= consumer_group.id %>, partitions: <%= partitions_list%>"
>
<%= topic_name %>:
<% if partitions.size > 10 %>
<%= "#{partitions.sort.first(10).join(',')}..." %>
<% else %>
<%= partitions.sort.join(',') %>
<% end %>
</span>
<% end %>
<% end %>
Version data entries
5 entries across 5 versions & 1 rubygems