theankurai / kafka-tutorial Goto Github PK

bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test_topic

bin/kafka-topics.sh --list --bootstrap-server localhost:9092

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test_tpoic

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test_topic

sudo systemctl enable --now zookeeper.service

sudo systemctl enable --now kafka.service

sudo systemctl status kafka zookeeper

tail -50 /usr/local/kafka-server/logs/server.log