show consumer groups in Topics view by shouples · Pull Request #3264 · confluentinc/vscode

Dave Shoup (shouples) · 2026-02-07T02:32:47Z

Summary of Changes

Adds consumer groups as a visible resource in the Topics view (pending rename in a future branch):

The Consumer Groups container is shown at the top in a collapsed state, while the (also new) Topics container is auto-expanded to be as minimally disruptive as possible for users.

Closes #3300

(Still more work to be done as part of the #3227 parent issue)

Associated PRs

set up ResourceContainer for Flink database and Kafka cluster child resources #3292
- show consumer groups in Topics view #3264 👈
  - add commands for consumer groups #3312

Click-testing instructions

Connect to a Confluent Cloud environment with an active Kafka cluster
Expand the Topics view for that cluster
Verify a "Consumer Groups" container appears alongside the "Topics" container
Expand the Consumer Groups container and confirm groups are listed with their state (if consumers have been active recently)
Expand a consumer group to verify its members (consumers) are shown

Optional: Any additional details or context that should be provided?

The downstream commands branch (placeholder in the stack) will add context menu actions for consumer groups (e.g. per-container refreshing, copying IDs)
Consumer group members are fetched per-group using Promise.allSettled, so one failed member fetch won't block the rest

Pull request checklist

Please check if your PR fulfills the following (if applicable):

Tests

Added new
Updated existing
Deleted existing

Release notes

Does anything in this PR need to be mentioned in the user-facing CHANGELOG?

sonarqube-confluent · 2026-02-28T00:01:46Z

Quality Gate failed

Failed conditions
76.9% Coverage on New Code (required ≥ 80%)

See analysis details on SonarQube

…r in CachingResourceLoader

…iew provider; update tests

…nsion doesn't support consumer group management

…vider

…ld group state; add tests

Dave Shoup (shouples) · 2026-03-12T21:13:04Z

package.json

-        {
-          "command": "confluent.topics.create",
-          "when": "view == confluent-topics && confluent.kafkaClusterSelected",
-          "group": "navigation@2"
-        },


Moved from the view/title section to view/item/context section since this is now shown inline on the "Topics" container item

Dave Shoup (shouples) · 2026-03-13T01:21:53Z

src/storage/resourceManager.ts

+   *
+   * Raises an error if the cluster ID of any consumer group does not match the given cluster's ID.
+   */
+  async setConsumerGroupsForCluster(


Really tempted to abstract this away into another variation of [set|get]KafkaClusterResource<T> like here:

vscode/src/storage/resourceManager.ts

Line 721 in 066658e

async setFlinkDatabaseResources<T extends { databaseId: string }>(

Copilot

Pull request overview

Adds Kafka consumer groups (and their member consumers) as a first-class, visible resource in the Topics view, backed by new loader + storage caching and updated tests to reflect the new containerized tree structure.

Changes:

Introduces root-level “Consumer Groups” and “Topics” containers in the Topics view provider and wires up tree item rendering/parenting for consumer groups and consumers.
Adds loader + ResourceManager support for fetching/caching consumer groups (including member hydration) and a small URL-parsing helper (parseCoordinatorId).
Updates unit/E2E tests, command placement (Create Topic inline action), and CHANGELOG entry.

Reviewed changes

Copilot reviewed 12 out of 12 changed files in this pull request and generated 7 comments.

Show a summary per file

File	Description
tests/e2e/objects/views/TopicsView.ts	Updates E2E view object to use the new Topics container and updated tree levels.
src/viewProviders/topics.ts	Adds containerized tree structure and consumer group/member support in the Topics view.
src/viewProviders/topics.test.ts	Expands unit coverage for new containers, consumer group behavior, and targeted tree refresh events.
src/storage/resourceManager.ts	Adds workspace-state caching for consumer groups with rehydration of groups and members.
src/storage/resourceManager.test.ts	Adds tests for consumer group cache set/get and rehydration behavior.
src/loaders/utils/loaderUtils.ts	Adds `parseCoordinatorId()` helper.
src/loaders/utils/loaderUtils.test.ts	Adds tests for consumer group/member error propagation and coordinator ID parsing.
src/loaders/resourceLoader.ts	Extends the ResourceLoader API with `getConsumerGroupsForCluster()`.
src/loaders/resourceLoader.test.ts	Adds tests for consumer group loading/caching behavior.
src/loaders/cachingResourceLoader.ts	Implements `getConsumerGroupsForCluster()` with caching + per-group member fetch.
package.json	Moves “Create Topic” from view title navigation to an inline action on the Topics container.
CHANGELOG.md	Documents the new consumer group visibility in the Topics view.

You can also share your feedback on Copilot code review. Take the survey.

src/viewProviders/topics.ts

+    // clear stale entries before repopulating
+    this.topicsInTreeView.clear();
+    this.subjectsInTreeView.clear();
+    this.subjectToTopicMap.clear();
+
    const loader = ResourceLoader.getInstance(cluster.connectionId);
    try {
      const topics = await loader.getTopicsForCluster(cluster, forceDeepRefresh);


src/viewProviders/topics.ts

+    // clear stale entries before repopulating
+    this.consumerGroupsInTreeView.clear();
+
+    const loader = ResourceLoader.getInstance(cluster.connectionId);
+    try {
+      const consumerGroups = await loader.getConsumerGroupsForCluster(cluster, forceDeepRefresh);


src/viewProviders/topics.ts

      this.logger.error("Error fetching topics for cluster", cluster, err);
+      const message = err instanceof Error ? err.message : String(err);
+      this.topicsContainer.setError(
+        new CustomMarkdownString()
+          .addWarning(`Failed to load topics for **${cluster.name}**:`)
+          .addCodeBlock(message),
+      );
      if (err instanceof TopicFetchError) {
        window.showErrorMessage(
          `Failed to list topics for cluster "${cluster.name}": ${err.message}`,
        );
      }


src/viewProviders/topics.ts

+        new CustomMarkdownString()
+          .addWarning(`Failed to load consumer groups for **${cluster.name}**:`)
+          .addCodeBlock(message),
+      );


src/loaders/cachingResourceLoader.ts

+    // Convert API response to ConsumerGroup models, fetching members for each group.
+    const consumerGroups: ConsumerGroup[] = await Promise.all(
+      responseConsumerGroups.map(async (data) => {
+        let members: Consumer[] = [];
+        try {
+          const memberData = await fetchConsumerGroupMembers(cluster, data.consumer_group_id);
+          members = memberData.map(


src/loaders/cachingResourceLoader.ts

+          state: data.state as ConsumerGroupState,
+          isSimple: data.is_simple,


tests/e2e/objects/views/TopicsView.ts

+  /** Get all topic items in the view (nested under the Topics container). */
  get topics(): Locator {
-    return this.body.locator("[role='treeitem'][aria-level='1']");
+    return this.body.locator("[role='treeitem'][aria-level='2']");


… item locators in the Topics view

sonarqube-confluent · 2026-03-13T04:02:04Z

Quality Gate passed

Issues
5 New issues
0 Fixed issues
0 Accepted issues

Measures
0 Security Hotspots
92.4% Coverage on New Code
0.0% Duplication on New Code

See analysis details on SonarQube

Lucia Cerchie (Cerchie) · 2026-03-13T18:37:31Z

src/loaders/utils/loaderUtils.ts

+  if (!related) return null;
+  const lastSegment = related.split("/").pop();
+  if (!lastSegment) return null;
+  const parsed = parseInt(lastSegment, 10);


I guess the SQ feedback makes sense here since we're already using Number anyhow

Dave Shoup (shouples) · 2026-03-14T00:24:52Z

Back to draft mode to address E2E test issues

This was referenced Feb 7, 2026

add consumer group service method to SidecarHandle and associated loader utils #3261

Merged

add consumer groups icon #3262

Merged

set up consumer group related models #3263

Merged

airlock-confluentinc bot force-pushed the djs/consumer-group-models branch 6 times, most recently from d5c9efc to 9b4450d Compare February 24, 2026 16:15

Dave Shoup (shouples) mentioned this pull request Feb 24, 2026

set up ResourceContainer for Flink database and Kafka cluster child resources #3292

Merged

4 tasks

Dave Shoup (shouples) changed the base branch from djs/consumer-group-models to djs/resource-container-refactor February 24, 2026 16:20

airlock-confluentinc bot force-pushed the djs/resource-container-refactor branch from 4384847 to 2d0df9f Compare February 24, 2026 22:01

airlock-confluentinc bot force-pushed the djs/consumer-groups-in-view branch from 099e61c to 8246ea3 Compare February 24, 2026 22:01

Dave Shoup (shouples) linked an issue Feb 26, 2026 that may be closed by this pull request

Show Consumer Groups container through Topics view provider #3300

Open

airlock-confluentinc bot force-pushed the djs/resource-container-refactor branch from 2d0df9f to 2daefec Compare February 26, 2026 16:49

airlock-confluentinc bot force-pushed the djs/consumer-groups-in-view branch 2 times, most recently from 25f8ed1 to 0b24f3d Compare February 27, 2026 14:41

airlock-confluentinc bot force-pushed the djs/resource-container-refactor branch 2 times, most recently from 6b8d9b8 to ec16f3d Compare February 27, 2026 14:48

airlock-confluentinc bot force-pushed the djs/consumer-groups-in-view branch 3 times, most recently from 3b61491 to a585b8b Compare February 27, 2026 22:39

Dave Shoup (shouples) mentioned this pull request Feb 28, 2026

add commands for consumer groups #3312

Draft

4 tasks

Base automatically changed from djs/resource-container-refactor to main March 10, 2026 20:34

Dave Shoup (shouples) added 5 commits March 10, 2026 16:37

add abstract getConsumerGroupsForCluster and set up default behavio…

333fdcc

…r in CachingResourceLoader

add get/set methods for consumer group storage

7df5d3c

add new event emitter for consumer group changes

c513dc1

add consumer group container and refresh/loading behavior to topics v…

cadea74

…iew provider; update tests

cast to enum

801a01c

Dave Shoup (shouples) added 3 commits March 10, 2026 16:37

push coordinator URL parsing logic into loaderUtils.ts and add tests

db7ddae

add try/catch for group members instead of allSettled

108a86b

remove consumerGroupsChanged event emitter and handler since the exte…

27c744f

…nsion doesn't support consumer group management

Copilot AI review requested due to automatic review settings March 10, 2026 20:38

airlock-confluentinc bot force-pushed the djs/consumer-groups-in-view branch from 9b6234e to 27c744f Compare March 10, 2026 20:38

Dave Shoup (shouples) review requested due to automatic review settings March 10, 2026 20:38

Dave Shoup (shouples) added 2 commits March 11, 2026 17:59

add tests for ConsumerGroup and Consumer handling within TopicViewPro…

70f7295

…vider

add ResourceLoader tests for fetching consumer groups and members

63a1dd3

Copilot AI review requested due to automatic review settings March 12, 2026 12:52

Dave Shoup (shouples) review requested due to automatic review settings March 12, 2026 12:52

fix bug where refreshing view after consumer groups start/stop show o…

066658e

…ld group state; add tests

Copilot AI review requested due to automatic review settings March 12, 2026 15:34

Dave Shoup (shouples) review requested due to automatic review settings March 12, 2026 15:34

Dave Shoup (shouples) commented Mar 12, 2026

View reviewed changes

Dave Shoup (shouples) commented Mar 13, 2026

View reviewed changes

Dave Shoup (shouples) marked this pull request as ready for review March 13, 2026 01:22

Dave Shoup (shouples) requested a review from a team as a code owner March 13, 2026 01:22

Copilot AI review requested due to automatic review settings March 13, 2026 01:22

Copilot started reviewing on behalf of Dave Shoup (shouples) March 13, 2026 01:23 View session

Copilot AI reviewed Mar 13, 2026

View reviewed changes

Dave Shoup (shouples) added 4 commits March 12, 2026 22:23

use showErrorNotificationWithButtons instead of basic error notification

5fb18ba

use executeInWorkerPool to prevent overwhelming request count

77d39fb

filter tree items by icon to avoid matching on consumer groups

e8ebaa0

use accessibilityInformation instead of tracking aria-levels for tree…

c6f90ee

… item locators in the Topics view

Lucia Cerchie (Cerchie) self-assigned this Mar 13, 2026

Lucia Cerchie (Cerchie) reviewed Mar 13, 2026

View reviewed changes

Dave Shoup (shouples) marked this pull request as draft March 14, 2026 00:24

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

show consumer groups in Topics view#3264

show consumer groups in Topics view#3264
Dave Shoup (shouples) wants to merge 29 commits intomainfrom
djs/consumer-groups-in-view

Dave Shoup (shouples) commented Feb 7, 2026 •

edited

Loading

Uh oh!

sonarqube-confluent bot commented Feb 28, 2026

Uh oh!

Dave Shoup (shouples) Mar 12, 2026

Uh oh!

Dave Shoup (shouples) Mar 13, 2026

Uh oh!

Copilot AI left a comment

Uh oh!

sonarqube-confluent bot commented Mar 13, 2026

Uh oh!

Lucia Cerchie (Cerchie) Mar 13, 2026

Uh oh!

Dave Shoup (shouples) commented Mar 14, 2026

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

3 participants

		state: data.state as ConsumerGroupState,
		isSimple: data.is_simple,

Conversation

Dave Shoup (shouples) commented Feb 7, 2026 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Summary of Changes

Associated PRs

Click-testing instructions

Optional: Any additional details or context that should be provided?

Pull request checklist

Tests

Release notes

Uh oh!

sonarqube-confluent bot commented Feb 28, 2026

Quality Gate failed

Uh oh!

Dave Shoup (shouples) Mar 12, 2026

Choose a reason for hiding this comment

Uh oh!

Dave Shoup (shouples) Mar 13, 2026

Choose a reason for hiding this comment

Uh oh!

Copilot AI left a comment

Choose a reason for hiding this comment

Pull request overview

Reviewed changes

Uh oh!

sonarqube-confluent bot commented Mar 13, 2026

Quality Gate passed

Uh oh!

Lucia Cerchie (Cerchie) Mar 13, 2026

Choose a reason for hiding this comment

Uh oh!

Dave Shoup (shouples) commented Mar 14, 2026

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

3 participants

Dave Shoup (shouples) commented Feb 7, 2026 •

edited

Loading