spring-cloud-stream-kafka-communication/kafka-command.md

Spring Boot Kafka Communication

##Commands

• Start Zookeeper

bin/zookeeper-server-start.sh config/zookeeper.properties

• Start Kafka

• Create Kafka topic

bin/kafka-topics.sh --create \
--topic first-topic \
--partitions=4 \
--replication-factor=1 \
--bootstrap-server localhost:9092

• List Kafka Topics

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

• Console consumer

bin/kafka-console-consumer.sh \
--bootstrap-server localhost:9092 \
--property key.separator=: \
--property print.key=true \
--property print.offset=true \
--property print.partition=true \
--property print.value=true \
--property print.headers=true \
--topic first-topic \
--from-beginning \
--group group1

• Console Consumer

bin/kafka-console-producer.sh \
--bootstrap-server localhost:9092 \
--property parse.key=true \
--property key.separator=: \
--topic first-topic

• Payload

mykey:"{\"name\": \"Jack\"}"