MCPcopy
hub / github.com/redpanda-data/console

github.com/redpanda-data/console @v3.8.0 sqlite

repository ↗ · DeepWiki ↗ · release v3.8.0 ↗
19,981 symbols 42,013 edges 2,120 files 4,668 documented · 23%
README

Redpanda Console – A UI for Data Streaming

GitHub release (latest SemVer) Docker Repository

Redpanda Console (previously known as Kowl) is a web application that helps you manage and debug your Kafka/Redpanda workloads effortlessly.

https://user-images.githubusercontent.com/23424570/220130537-7b0b8596-0a06-4132-90a5-1be3c169e4f4.mp4

Features

  • Message viewer: Explore your topics' messages in our message viewer through ad-hoc queries and dynamic filters. Find any message you want using JavaScript functions to filter messages. Supported encodings are: JSON, Avro, Protobuf, CBOR, XML, MessagePack, Text and Binary (hex view). The used encoding (except Protobuf and CBOR) is recognized automatically.
  • Consumer groups: List all your active consumer groups along with their active group offsets, edit group offsets (by group, topic or partition) or delete a consumer group.
  • Topic overview: Browse through the list of your Kafka topics, check their configuration, space usage, list all consumers who consume a single topic or watch partition details (such as low and high water marks, message count, ...), embed topic documentation from a git repository and more.
  • Cluster overview: List available brokers, their space usage, rack id, health, configuration and other information to get a high level overview of your brokers in your cluster.
  • Security: Create, list or edit Kafka ACLs and SASL-SCRAM users.
  • Schema Registry: List and manage all aspects of your Avro, Protobuf or JSON schemas within your schema registry.
  • Kafka connect: Manage connectors from multiple connect clusters, patch configs, view their current state or restart tasks.
  • Redpanda Transforms: Manage and monitor data transforms deployed in your Redpanda cluster.

Code Quality

The frontend uses react-doctor to statically analyze React components for performance anti-patterns. Run bun run doctor in the frontend/ directory for a local scan. React Doctor also runs automatically in CI on every push and pull request.

Getting Started

Prerequisites

  • Redpanda or any Kafka deployment (v1.0.0+) compatible
  • A web browser to access the Console, which can be deployed using Docker builds or as a single binary across all platforms (amd64 / arm64)

Installing

We offer pre built docker images for RP Console, binary builds and a Helm chart to make the installation as comfortable as possible for you. Please take a look at our dedicated Installation documentation.

Quick Start

Do you just want to test RP Console against one of your Kafka clusters without spending too much time on the test setup? Here are some docker commands that allow you to run it locally against an existing Redpanda or Kafka cluster:

Redpanda/Kafka is running locally

Since Console runs in its own container (which has its own network scope), we have to use host.docker.internal as a bootstrap server. That DNS resolves to the host system's ip address. However since the brokers send a list of all brokers' DNS when a client has connected, you have to make sure your advertised listener is connected accordingly, e.g.: PLAINTEXT://host.docker.internal:9092

docker run -p 8080:8080 -e KAFKA_BROKERS=host.docker.internal:9092 docker.redpanda.com/redpandadata/console:latest

Docker supports the --network=host option only on Linux. So Linux users use localhost:9092 as an advertised listener and use the host network namespace instead. Console will then be run as it would be executed on the host machine.

docker run --network=host -p 8080:8080 -e KAFKA_BROKERS=localhost:9092 docker.redpanda.com/redpandadata/console:latest

Kafka is running remotely

Protected via SASL_SSL and trusted certificates (e.g. Confluent Cloud):

docker run -p 8080:8080 -e KAFKA_BROKERS=pkc-4r000.europe-west1.gcp.confluent.cloud:9092 -e KAFKA_TLS_ENABLED=true -e KAFKA_SASL_ENABLED=true -e KAFKA_SASL_USERNAME=xxx -e KAFKA_SASL_PASSWORD=xxx docker.redpanda.com/redpandadata/console:latest

I don't have a running Kafka cluster to test against

We maintain a docker-compose file that launches Redpanda and Console: /docs/local.

Community

Slack is the main way the community interacts with one another in real time :)

GitHub Issues can be used for issues, questions and feature requests.

Code of conduct code of conduct for the community

Contributing docs

Extension points exported contracts — how you extend this code

ConfigPatch (Interface)
ConfigPatch is an interface that can be implemented to patch one or more aspects of a configuration that exists in one o [18 …
backend/pkg/connector/patch/patch.go
FullscreenRouteNode (Interface)
* The slice of a TanStack route node this module reads. A built route exposes * `path`/`staticData` under `options`; a
frontend/src/utils/fullscreen-routes.ts
SecurityServiceClient (Interface)
SecurityServiceClient is a client for the redpanda.api.console.v1alpha1.SecurityService service. [10 implementers]
backend/pkg/protogen/redpanda/api/console/v1alpha1/consolev1alpha1connect/security.connect.go
SpeechRecognition (Interface)
(no doc) [1 implementers]
frontend/src/components/ai-elements/prompt-input.tsx
SecurityServiceHandler (Interface)
SecurityServiceHandler is an implementation of the redpanda.api.console.v1alpha1.SecurityService service. [10 implementers]
backend/pkg/protogen/redpanda/api/console/v1alpha1/consolev1alpha1connect/security.connect.go
Window (Interface)
(no doc)
frontend/src/app.tsx
LicenseServiceClient (Interface)
LicenseServiceClient is a client for the redpanda.api.console.v1alpha1.LicenseService service. [6 implementers]
backend/pkg/protogen/redpanda/api/console/v1alpha1/consolev1alpha1connect/license.connect.go
Register (Interface)
(no doc)
frontend/src/app.tsx

Core symbols most depended-on inside this repo

expect
called by 4474
frontend/src/utils/interpreter/helpers.ts
create
called by 955
frontend/src/state/backend-api.ts
cancel
called by 901
frontend/src/components/pages/connect/helper.tsx
Handle
called by 554
backend/pkg/logger/prometheus.go
cn
called by 538
frontend/src/components/redpanda-ui/lib/utils.tsx
Error
called by 492
backend/pkg/console/kafka_error.go
String
called by 429
backend/pkg/bsr/client.go
goto
called by 196
frontend/tests/test-variant-console/utils/acl-page.ts

Shape

Method 11,441
Function 5,988
Struct 1,690
Interface 408
Class 225
Enum 121
TypeAlias 104
FuncType 4

Languages

Go75%
TypeScript25%

Modules by API surface

backend/pkg/protogen/redpanda/api/dataplane/v1alpha3/knowledge_base.pb.go525 symbols
backend/pkg/protogen/redpanda/api/dataplane/v1/pipeline.pb.go372 symbols
backend/pkg/protogen/redpanda/api/dataplane/v1alpha3/ai_agent.pb.go326 symbols
backend/pkg/protogen/redpanda/api/dataplane/v1alpha2/kafka_connect.pb.go305 symbols
backend/pkg/protogen/redpanda/api/dataplane/v1alpha1/kafka_connect.pb.go305 symbols
backend/pkg/protogen/redpanda/api/dataplane/v1/kafka_connect.pb.go305 symbols
backend/pkg/protogen/redpanda/api/dataplane/v1/topic.pb.go247 symbols
backend/pkg/protogen/redpanda/api/dataplane/v1/secret.pb.go239 symbols
backend/pkg/protogen/redpanda/api/dataplane/v1/mcp.pb.go227 symbols
backend/pkg/protogen/redpanda/api/dataplane/v1alpha2/pipeline.pb.go226 symbols
backend/pkg/protogen/redpanda/api/dataplane/v1alpha3/mcp.pb.go216 symbols
backend/pkg/protogen/redpanda/api/console/v1alpha1/debug_bundle.pb.go207 symbols

Dependencies from manifests, versioned

buf.build/gen/go/bufbuild/protovalidate/protocolbuffers/gov1.36.11-20260209202 · 1×
buf.build/gen/go/bufbuild/registry/connectrpc/gov1.19.1-202510271521 · 1×
buf.build/gen/go/bufbuild/registry/protocolbuffers/gov1.36.10-20251027152 · 1×
buf.build/gen/go/redpandadata/common/protocolbuffers/gov1.36.11-20260316210 · 1×
buf.build/gen/go/redpandadata/core/connectrpc/gov1.19.1-202602261202 · 1×
buf.build/gen/go/redpandadata/core/protocolbuffers/gov1.36.11-20260313213 · 1×
buf.build/gen/go/redpandadata/otel/protocolbuffers/gov1.36.11-20251216164 · 1×
buf.build/go/protovalidatev1.0.1 · 1×
cel.dev/exprv0.25.1 · 1×
connectrpc.com/connectv1.19.1 · 1×
connectrpc.com/grpcreflectv1.3.0 · 1×
cuelang.org/gov0.14.2 · 1×

Datastores touched

(mongodb)Database · 1 repos
dbDatabase · 1 repos

For agents

$ claude mcp add console \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact