Spring Cloud(MSA)

kafka 테스트할때 명령어 메모

lby132 2022. 9. 27. 21:46

./bin/kafka-topics.sh --list --boostrap-server localhost:9092 카프카 토픽에 있는 리스트 조회 

 

./bin/kafka-console-producer.sh —broker-list localhost:9092 —topic my_topic_users.   my_topic_users라는 토픽에 저장된 리스트 조회

 

./bin/kafka-console-consumer.sh —bootstrap-server localhost:9092 —topic quickstart-events —from-beginning quickstart-events라는 토픽 만들기 

 

./bin/kafka-server-start.sh ./config/server.properties  카프카 서버 스타트

 

./bin/zookeeper-server-start.sh ./config/zookeeper.properties 주키퍼 서버 스타트

 

./bin/connect-distributed ./etc/kafka/connect-distributed.properties  카프카 커넥트

 

./bin/kafka-console-producer.sh -broker-list localhost:9092 -topic my_topic_users 프로듀스(데이터 공급)

 

./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --from-beginning --topic my_topic_users 컨슈머(데이터 소비)

 

'Spring Cloud(MSA)' 카테고리의 다른 글

아파치 카프카  (0) 2022.09.28
Resilience4J = CircuirtBreaker  (1) 2022.09.28
Spring Cloud Bus(with RabbitMq)  (0) 2022.09.24
Symmetric, Asymmetric  (0) 2022.09.24
Spring Cloud Config  (0) 2022.09.22