This is an automated email from the ASF dual-hosted git repository.
abhishekrb19 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
The following commit(s) were added to refs/heads/master by this push:
new a0b1e509b81 feat(web-console): show stream partition count on the
supervisors table (#20619)
a0b1e509b81 is described below
commit a0b1e509b81b6c59f18d55b7677fed3044952652
Author: Abhishek Radhakrishnan <[email protected]>
AuthorDate: Sat Oct 17 22:27:27 2026 -0700
feat(web-console): show stream partition count on the supervisors table
(#20619)
The web console supervisors view now shows the stream partition count in
the Details column next to aggregate lag for Kafka, Kinesis, and Rabbit
supervisors.
---
.../src/views/supervisors-view/supervisors-view.tsx | 21 ++++++++++++++++-----
1 file changed, 16 insertions(+), 5 deletions(-)
diff --git a/web-console/src/views/supervisors-view/supervisors-view.tsx
b/web-console/src/views/supervisors-view/supervisors-view.tsx
index 4c255fd2bd1..8714c443195 100644
--- a/web-console/src/views/supervisors-view/supervisors-view.tsx
+++ b/web-console/src/views/supervisors-view/supervisors-view.tsx
@@ -1064,11 +1064,22 @@ export class SupervisorsView extends
React.PureComponent<
status[value]?.payload;
if (oneOf(original.type, 'kafka', 'kinesis', 'rabbit')) {
const aggregateLag = supervisorStatusPayload?.aggregateLag;
- return isNumberLike(aggregateLag) ? (
- <span data-tooltip="Aggregate lag across all tasks">{`Lag:
${formatInteger(
- aggregateLag,
- )}`}</span>
- ) : null;
+ const partitions = supervisorStatusPayload?.partitions;
+ if (!isNumberLike(aggregateLag) && !isNumberLike(partitions))
return null;
+ return (
+ <>
+ {isNumberLike(aggregateLag) && (
+ <div data-tooltip="Aggregate lag across all tasks">{`Lag:
${formatInteger(
+ aggregateLag,
+ )}`}</div>
+ )}
+ {isNumberLike(partitions) && (
+ <div data-tooltip="Number of partitions in the
stream">{`Partitions: ${formatInteger(
+ partitions,
+ )}`}</div>
+ )}
+ </>
+ );
} else if (original.type === 'autocompact') {
const compactionConfig = original.spec?.spec as CompactionConfig
| undefined;
if (!supervisorStatusPayload || !compactionConfig) return null;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
