[Kafka] Kafka Producer/Consumer

Kafka 서버 기동

• Zookeeper 및 Kafka 서버 구동

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

$KAFKA_HOME/bin/kafka-server-start.sh $KAFKA_HOME/config/server.properties

• Topic 생성

$KAFKA_HOME/bin/kafka-topics.sh --create--topic quickstart-events--bootstrap-server localhost:9092\--partitions 1

• Topic 목록 확인

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

• Topic 정보 확인

$KAFKA_HOME/bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092

메시지 생산 및 소비

• 메시지 생산

$KAFKA_HOME/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic quickstart-events

• 메시지 소비

$KAFKA_HOME/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic quickstart-events \ --from-beginning

출처

https://kafka.apache.org/quickstart
Spring Cloud로 개발하는 마이크로서비스 애플리케이션(MSA)