See your cluster
Topics, partitions, consumer groups, lag, replicas, and record counts, refreshed every 30 seconds by default.
Kafka in your terminal.
Browse and manage topics and consumer groups, and read records as JSON, Avro, or Protobuf, with or without Schema Registry. All from the keyboard.
brew install kaskade
Latest release View releases ↗
Open source · Python 3.10+ · macOS & Linux
Features
What it does
Two commands: kaskade admin for topics and consumer groups, and kaskade consumer for records.
Change topics
Create, edit, delete, and filter topics, and check their configuration, from the same screen.
Start where you need
Read from the latest or earliest offsets, or from exact partitions and offsets.
Decode records
Bytes, primitives, JSON, Avro, and Protobuf, with local schemas or through Confluent Schema Registry or Apicurio Registry.
See broken records too
A key, value, or header that fails to decode shows up as bytes next to the error, and consuming carries on.
Connect to your cluster
Keep connection settings in a client.ini file and connect over TLS, SASL, Confluent Cloud, or Amazon MSK IAM.
Screenshots
Admin and consumer
Both work entirely from the keyboard, with arrow keys or Vim-style shortcuts.
Admin Browse and manage topics.
topics · partitions · groups · lag
Consumer Read and filter records.
filter · deserialize · copy · export
Install
Quick start
Install with Homebrew or pipx, then point Kaskade at a broker or a client.ini file.
Option A
Homebrew
brew install kaskade
Option B
pipx
pipx install kaskade
Then connect
Replace the example broker, topic, and options with your own.
Admin
kaskade admin -b my-kafka:9092
Consumer
kaskade consumer -b my-kafka:9092 -t my-topic
Profile
kaskade admin --config-file client.ini
Links
Docs and community
Thanks
