Trying to learn how kafka works!
Steps To Connect To Kafka:
-
zookeeper-server-start.sh ~/kafka_2.12-3.7.0/config/zookeeper.properties
-
kafka-server-start.sh ~/kafka_2.12-3.7.0/config/server.properties
-
kafka-topics.sh --bootstrap-server localhost:9092 --topic first_topic --create --partitions 3 --replication-factor 1
Steps 1,2,3 help us to start kafka server and create a topic with name as "first_topic"
Below are some useful commands to check topic details and start the consumer and see the consumed messages:
-
kafka-topics.sh --bootstrap-server localhost:9092 --alter --topic topic1 --partitions 5
-
kafka-topics.sh --bootstrap-server localhost:9092 --alter --topic topic1 --partitions 5
-
kafka-console-producer.sh --bootstrap-server localhost:9092 --topic first_topic
-
kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic first_topic --from-beginning
-
kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic first_topic --from-beginning