<% 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| %> <%= topic_name %>: <% if partitions.size > 10 %> <%= "#{partitions.sort.first(10).join(',')}..." %> <% else %> <%= partitions.sort.join(',') %> <% end %> <% end %> <% end %>
<%== tags(process.tags) %>