WORKING ON KAFKA TOPIC

Command to create kafka topic

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

To list all the topics exist on the kafka server

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

To delete an existing topic

bin/kafka-topics.sh config/server.properties --bootstrap-server localhost:9092 --delete --topic Patients-Vitals-Info

Leave a Reply