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

vend/kafkaCLI

Folders and files

NameName
Last commit message
Last commit date

Latest commit

Β 

History

24 Commits
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 

Repository files navigation

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