Sha256: b1119ace2c7807a807dd173c91aa3c02424e9bb9bc2125d9170ed9116b38eb25

Contents?: true

Size: 1.2 KB

Versions: 1

Compression:

Stored size: 1.2 KB

Contents

<tr>
  <td>
    <%= topic.name %>
  </td>
  <td>
    <%= partition.id %>
  </td>
  <td>
    <% if partition.lag_stored.to_i < 0 %>
      <span class="badge bg-secondary" title="Not available until first offset commit">
        N/A
      </span>
    <% else %>
      <%= partition.lag_stored %>
    <% end %>
  </td>
  <td>
    <span class="badge <%= lag_trend_bg(partition.lag_stored_d) %>">
      <%= partition.lag_stored_d %>
    </span>
  </td>
  <td>
    <% if partition.committed_offset.to_i < 0 %>
      <span class="badge bg-secondary" title="Not available until first offset commit">
        N/A
      </span>
    <% else %>
      <%= partition.committed_offset %>
    <% end %>
  </td>
  <td>
    <% if partition.stored_offset.to_i < 0 %>
      <span class="badge bg-secondary" title="Not available until first offset commit">
        N/A
      </span>
    <% else %>
      <%= partition.stored_offset %>
    <% end %>
  </td>
  <td>
    <span class="badge <%= kafka_state_bg(partition.fetch_state) %> mt-1 mb-1">
      <%= partition.fetch_state %>
    </span>
  </td>
  <td>
    <span class="badge <%= kafka_state_bg(partition.poll_state) %> mt-1 mb-1">
      <%= partition.poll_state %>
    </span>
  </td>
</tr>

Version data entries

1 entries across 1 versions & 1 rubygems

Version Path
karafka-web-0.4.1 lib/karafka/web/ui/pro/views/consumers/consumer/_partition.erb