Kaskade is a text user interface (TUI) for Apache Kafka, built with Textual. It includes features like:
- Admin:
- List topics, partitions, groups and group members
- Topic information like lag, replicas, records count
- Create and delete topics
- Consumer:
- Json, string, integer and double deserialization
Install with pipx
:
pipx install kaskade
pipx
will installkaskade
andkskd
aliases.
Upgrade with pipx
:
pipx upgrade kaskade
Help:
kaskade --help
kaskade admin --help
kaskade consumer --help
Admin view:
kaskade admin -b localhost:9092
Consumer view:
kaskade consumer -b localhost:9092 -t my-topic
SSL encryption example:
kaskade admin -b localhost:9092 -x security.protocol=SSL
For more information about SSL encryption and SSL authentication go to the
librdkafka
official page: Configure librdkafka client.
Multiple bootstrap servers:
kaskade admin -b broker1:9092,broker2:9092
Confluent cloud:
kaskade admin -b ${BOOTSTRAP_SERVERS} \
-x security.protocol=SASL_SSL \
-x sasl.mechanism=PLAIN \
-x sasl.username=${CLUSTER_API_KEY} \
-x sasl.password=${CLUSTER_API_SECRET}
Consume and deserialize:
kaskade consumer -b localhost:9092 -t my-topic -k json -v json
Consuming from the beginning:
kaskade consumer -b localhost:9092 -x auto.offset.reset=earliest
For development instructions see DEVELOPMENT.md.