Skip to content
This repository has been archived by the owner on May 30, 2024. It is now read-only.

Latest commit

 

History

History
18 lines (13 loc) · 475 Bytes

README.md

File metadata and controls

18 lines (13 loc) · 475 Bytes

kafkaCLI

The CLI tools that ship with Kafka are super slow, so I thought I'd implement a subset of it in GO.

Currently only topic creation, deletion and listing is supported.

kafkaCLI createTopic --bootstrap-server kafka:9092 --partitions 4 --replication-factor 1 --config message.format.version=2.0 --if-not-exists topic1 topic2
kafkaCLI deleteTopic --bootstrap-server kafka:9092 topic1 topic2
kafkaCLI listTopics --bootstrap-server kafka:9092