kafka

# To create a topic bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 2 --topic adserver-events # To open producer console bin/./kafka-console-producer.sh --broker-list 10.224.76.52:9092 --topic orders-event-topic # To open consumer console ./bin./kafka-console-consumer.sh --bootstrap-server 10.224.76.52:9092 --topic orders-event-topic --from-beginning # To list all the topics ./kafka-topics.sh --list --zookeeper localhost:2181 # To start zookeper service ./bin/zookeeper-server-start.sh config/zookeeper.properties > /mnt/zookeeper-logs/zookeeper-log.log & # To Start kafka service ./bin/kafka-server-start.sh config/server.properties > /mnt/kafka-logs/kafkalogs.log & # To get partition count of perticular topic ./kafka-topics.sh --describe --zookeeper localhost:2181 --topic adserver-events # To get consumer-group details ./kafka-consumer-groups.sh --list --bootstrap-server 10.224.76.52:9092 # To manually assign consumer group Id to a topic ./kafka-console-consumer.sh --bootstrap-server 10.224.76.52:9092 --group consumer-stage- --topic orders-event-topic --from-beginning # to delete group Id from kafka manulaly ./kafka-consumer-groups.sh --bootstrap-server 10.224.76.52:9092 --delete --group consumer-stage- # To delete topic ./kafka-topics.sh --zookeeper localhost:2181 --delete --topic orders-event-topic

Apr 23, 2025 - 15:39

# To create a topic
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 2 --topic adserver-events

# To open producer console
bin/./kafka-console-producer.sh --broker-list 10.224.76.52:9092 --topic orders-event-topic

# To open consumer console
./bin./kafka-console-consumer.sh --bootstrap-server 10.224.76.52:9092 --topic orders-event-topic --from-beginning

# To list all the topics
./kafka-topics.sh --list --zookeeper localhost:2181

# To start zookeper service
./bin/zookeeper-server-start.sh config/zookeeper.properties > /mnt/zookeeper-logs/zookeeper-log.log &

# To Start kafka service
./bin/kafka-server-start.sh config/server.properties > /mnt/kafka-logs/kafkalogs.log &

# To get partition count of perticular topic
./kafka-topics.sh --describe --zookeeper localhost:2181 --topic adserver-events

# To get consumer-group details
./kafka-consumer-groups.sh --list --bootstrap-server 10.224.76.52:9092

# To manually assign consumer group Id to a topic
./kafka-console-consumer.sh --bootstrap-server 10.224.76.52:9092 --group consumer-stage- --topic orders-event-topic --from-beginning

# to delete group Id from kafka manulaly
./kafka-consumer-groups.sh --bootstrap-server 10.224.76.52:9092 --delete --group consumer-stage-

# To delete topic
./kafka-topics.sh --zookeeper localhost:2181 --delete --topic orders-event-topic