npm

kafka

Distributed event streaming platform for building real-time data pipelines

brewmacoslinux

Try with needOr install directly

Source

About

Open-source distributed event streaming platform

Commands

kafka-topics.shkafka-console-producer.shkafka-console-consumer.shkafka-broker-api-versions.shkafka-configs.shkafka-consumer-groups.sh

Examples

Create a new topic with 3 partitions and replication factor of 1$ kafka-topics.sh --create --topic my-topic --partitions 3 --replication-factor 1 --bootstrap-server localhost:9092

Produce messages to a topic from console$ kafka-console-producer.sh --topic my-topic --bootstrap-server localhost:9092

Consume messages from a topic starting from the beginning$ kafka-console-consumer.sh --topic my-topic --from-beginning --bootstrap-server localhost:9092