kafka 테스트할때 명령어 메모

./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 컨슈머(데이터 소비)