<%= consumer_group.id %>

State: <%= consumer_group[:state][:state] %>

Join state: <%= consumer_group.join_state %>

State change: <%== relative_time( Time.at(@process.dispatched_at) - (consumer_group.stateage / 1_000) ) %>

Last rebalance: <%== relative_time( Time.at(@process.dispatched_at) - (consumer_group.rebalance_age / 1_000) ) %>

Rebalance count: <%= consumer_group.rebalance_cnt %>

Last rebalance reason: <%= consumer_group.rebalance_reason %>

<% if consumer_group.topics.empty? %>

This process does not consume any messages from any topics of this consumer group.

<% else %>

<% consumer_group.topics.each do |topic| %> <% topic.partitions.each do |partition| %> <%== partial( 'consumers/consumer/partition', locals: { topic: topic, partition: partition, consumer_group: consumer_group } ) %> <% end %> <% end %>

Topic	Partition	Lag stored	Lag trend	Committed offset	Stored offset	Fetch state	Poll state

<% end %>