Merge pull request #4842 from ebarriosjr/add-column-to-kafka-plugin-for-lag

Added lag column to the kafka plugin

.changeset/curvy-poems-cough.md

@@ -0,0 +1,5 @@
+---
+'@backstage/plugin-kafka': patch
+---
+
+Added lag column in the plugin main table

plugins/kafka/src/components/ConsumerGroupOffsets/ConsumerGroupOffsets.test.tsx

@@ -37,5 +37,10 @@ describe('ConsumerGroupOffsets', () => {
     expect(rendered.getByText(/consumer/)).toBeInTheDocument();
     expect(rendered.getByText('topic1')).toBeInTheDocument();
     expect(rendered.getByText('topic2')).toBeInTheDocument();
+
+    const lag = (
+      +data.offsets[1].topicOffset - +data.offsets[1].groupOffset
+    ).toString();
+    expect(rendered.getByText(lag)).toBeInTheDocument();
   });
 });

plugins/kafka/src/components/ConsumerGroupOffsets/ConsumerGroupOffsets.tsx

@@ -57,6 +57,17 @@ const generatedColumns: TableColumn[] = [
       return <>{row.groupOffset ?? ''}</>;
     },
   },
+  {
+    title: 'Lag',
+    field: 'lag',
+    render: (row: Partial<TopicPartitionInfo>) => {
+      let lag = undefined;
+      if (row.topicOffset && row.groupOffset) {
+        lag = +row.topicOffset - +row.groupOffset;
+      }
+      return <>{lag ?? ''}</>;
+    },
+  },
 ];
 
 type Props = {