Confluent

Confluent Streams Group (v3) API

[![Early Access](https://img.shields.io/badge/Lifecycle%20Stage-Early%20Access-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy)

GitHub OpenAPI

Operations 12

Each operation below carries the questions people ask an LLM about it and the instructions they give an agent to run it. Generated by API Evangelist overlay

GET /kafka/v3/clusters/{cluster_id}/streams-groups List Kafka Streams groups on a cluster · List Streams Groups #
Ask an LLM
“Which Kafka Streams applications are registered as streams groups on my Confluent cluster?”
“Can I see every streams group running against one Kafka cluster?”
Tell an agent
List the streams groups on Kafka cluster {cluster_id}.
Show me all Kafka Streams groups in cluster {cluster_id}.
GET /kafka/v3/clusters/{cluster_id}/streams-groups/{group_id} Get details of one streams group · Get Streams Group #
Ask an LLM
“What state is a particular Kafka Streams group in right now?”
“How do I look up a single streams group by its group ID?”
Tell an agent
Get streams group {group_id} on cluster {cluster_id}.
Show the details of Kafka Streams group {group_id} in cluster {cluster_id}.
GET /kafka/v3/clusters/{cluster_id}/streams-groups/{group_id}/subtopologies List subtopologies of a streams group · List Streams Group Subtopologies #
Ask an LLM
“What subtopologies make up my Kafka Streams group's topology?”
“Can I list all the subtopologies a streams group is processing?”
Tell an agent
List the subtopologies of streams group {group_id} on cluster {cluster_id}.
Show every subtopology in Kafka Streams group {group_id}, cluster {cluster_id}.
GET /kafka/v3/clusters/{cluster_id}/streams-groups/{group_id}/subtopologies/{subtopology_id} Get one subtopology of a streams group · Get Streams Group Subtopology #
Ask an LLM
“Which source topics feed a specific subtopology in my streams group?”
“How do I inspect one subtopology of a Kafka Streams group by its ID?”
Tell an agent
Get subtopology {subtopology_id} of streams group {group_id} on cluster {cluster_id}.
Show details for subtopology {subtopology_id} in streams group {group_id}, cluster {cluster_id}.
GET /kafka/v3/clusters/{cluster_id}/streams-groups/{group_id}/members List members of a streams group · List Streams Group Members #
Ask an LLM
“Which Kafka Streams instances are currently members of my streams group?”
“Can I see how many members have joined a streams group?”
Tell an agent
List the members of streams group {group_id} on cluster {cluster_id}.
Show all instances that belong to Kafka Streams group {group_id} in cluster {cluster_id}.
GET /kafka/v3/clusters/{cluster_id}/streams-groups/{group_id}/members/{member_id} Get one member of a streams group · Get Streams Group Member #
Ask an LLM
“What do I know about a single member of a Kafka Streams group?”
“How do I look up one streams group member by member ID?”
Tell an agent
Get member {member_id} of streams group {group_id} on cluster {cluster_id}.
Show details of streams member {member_id} in group {group_id}, cluster {cluster_id}.
GET /kafka/v3/clusters/{cluster_id}/streams-groups/{group_id}/members/{member_id}/assignments Get a streams member's current assignments · Get Streams Group Member Assignments #
Ask an LLM
“Which tasks is a Kafka Streams member currently assigned?”
“Can I see the current (not target) assignment of one streams group member?”
Tell an agent
Get the current assignments of member {member_id} in streams group {group_id} on cluster {cluster_id}.
Show what streams member {member_id} of group {group_id} is working on now, cluster {cluster_id}.
GET /kafka/v3/clusters/{cluster_id}/streams-groups/{group_id}/members/{member_id}/target-assignments Get a streams member's target assignments · Get Streams Group Member Target Assignments #
Ask an LLM
“What is the target assignment a streams member is being rebalanced toward?”
“Can I compare where a Kafka Streams member is headed after a rebalance?”
Tell an agent
Get the target assignments of member {member_id} in streams group {group_id} on cluster {cluster_id}.
Show which tasks streams member {member_id} of group {group_id} should end up with, cluster {cluster_id}.
GET /kafka/v3/clusters/{cluster_id}/streams-groups/{group_id}/members/{member_id}/assignments/{assignments_type} List a member's current tasks of one type · List Streams Group Assignments of a Specific Type #
Ask an LLM
“Which active or standby tasks does a streams member currently hold?”
“Can I filter a streams member's current assignment to a single task type?”
Tell an agent
List the current {assignments_type} tasks of member {member_id} in streams group {group_id}, cluster {cluster_id}.
Show member {member_id}'s assigned {assignments_type} tasks now in group {group_id} on cluster {cluster_id}.
GET /kafka/v3/clusters/{cluster_id}/streams-groups/{group_id}/members/{member_id}/target-assignments/{assignments_type} List a member's target tasks of one type · List Streams Group Target Assignments of a Specific Type #
Ask an LLM
“Which tasks of a given type will a streams member hold once rebalancing finishes?”
“Can I see only the target standby or active tasks planned for a streams member?”
Tell an agent
List the target {assignments_type} tasks for member {member_id} in streams group {group_id}, cluster {cluster_id}.
Show the planned {assignments_type} tasks for streams member {member_id}, group {group_id}, cluster {cluster_id}.
GET /kafka/v3/clusters/{cluster_id}/streams-groups/{group_id}/members/{member_id}/assignments/{assignments_type}/subtopologies/{subtopology_id} List partitions of a member's current subtopology tasks · List Streams Group Assignments Task Partitions of a Specific Type and… #
Ask an LLM
“Which partitions does a streams member currently own for one subtopology?”
“How do I drill into the partitions behind a member's current tasks in a subtopology?”
Tell an agent
List the partitions of member {member_id}'s current {assignments_type} tasks in subtopology {subtopology_id}, group {group_id}, cluster {cluster_id}.
Show current task partitions for streams member {member_id}, type {assignments_type}, subtopology {subtopology_id}, group {group_id} on {cluster_id}.
GET /kafka/v3/clusters/{cluster_id}/streams-groups/{group_id}/members/{member_id}/target-assignments/{assignments_type}/subtopologies/{subtopology_id} List partitions of a member's target subtopology tasks · List Streams Group Target Assignments Task Partitions of a Specific Type and… #
Ask an LLM
“Which partitions will a streams member be given for one subtopology after the rebalance?”
“Can I see the target partition assignment for a member's tasks in a single subtopology?”
Tell an agent
List the target partitions of member {member_id}'s {assignments_type} tasks in subtopology {subtopology_id}, group {group_id}, cluster {cluster_id}.
Show planned task partitions for streams member {member_id}, type {assignments_type}, subtopology {subtopology_id}, group {group_id} on {cluster_id}.

Documentation

📖
APIReference
https://docs.confluent.io/cloud/current/api.html
📖
APIReference
https://api.telemetry.confluent.cloud/docs

Specifications

⚙
OpenAPI
https://raw.githubusercontent.com/api-evangelist/confluent/refs/heads/main/openapi/confluent-streams-group-v3-api-openapi.yml

Work with this as data

Every API here is available over the APIs.io API and to AI agents over MCP.

MCP server

One button, every client — Claude, Cursor, VS Code and the rest.

https://apis.io/mcp

Tools for apis

7 MCP tools reach this
  • find_apisBrowse and filter every API in the catalog.
  • get_api_artifactsOne API's artifacts, grouped by type.
  • get_openapiThe primary OpenAPI for this API.
  • find_similar_apisAPIs that look like this one.
  • apis_io_searchSTART HERE — APIs, providers and tags for one query, each with its total.
  • resolveTurn a domain, URL or GitHub org into the provider it belongs to.
  • find_cohortsEvery scored population of providers in the catalog.
All 92 tools →

Call it yourself

curl for this page
This API 
curl "https://apis.io/api/v1/apis/confluent:confluent-streams-group-v3-api"
All apis 
curl "https://apis.io/api/v1/apis?limit=25"

Discovery needs no key. Ratings and market analysis are Pro.

Get an API key

Free tier, no form to fill in. Signing in shares your email address with us — we store it to create your key and to recognise you if you sign in with another provider. See our Privacy Policy and Terms.

GitHub Google LinkedIn

A second provider on the same verified email joins the account you already have.

OpenAPI Specification

confluent-streams-group-v3-api-openapi.yml Raw ↑ 
openapi: 3.2.0
info:
  title: Confluent Streams Group (v3) API
  version: ''
  x-api-id: 46234552-5833-42eb-ba0f-883ad3f70d2b
  x-audience: external-public
  x-logo:
    url: https://assets.confluent.io/m/1661ef5e4ff82d3d/
  description: 'Operations tagged Streams Group (v3) across 2 of this provider''s published API definitions: confluent-cloud-openapi.yaml, confluent-cloud-full.yaml. Each path carries the servers of the definition it was published in.'
servers:
- url: https://api.confluent.cloud
  description: Confluent Cloud API
tags:


# --- truncated at 32 KB (47 KB total) ---
# Full source: https://raw.githubusercontent.com/api-evangelist/confluent/refs/heads/main/openapi/confluent-streams-group-v3-api-openapi.yml