자바/카프카/2021-08-20/ Kafka 개발환경 설정
Zookeeper 홈 https://zookeeper.apache.org/releases.html 에 접속한다
zoo.cfg 파일을 열어서 data 경로를 재조정한다.
주키퍼를 실행한다.
카프카(https://kafka.apache.org/ )에 접속 후 다운로드 받는다.
환경변수를 설정합니다.
cmd 창을 오픈한다
새로운 cmd 창을 오픈한다. kafka-console-consumer 창이 된다.
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic hello-kafka
를 입력한다. topic 생성 응답이 뜬다. kafka-topics.bat --list --zookeeper localhost:2181 hello-kafka 를 입력한다.
또 다른 cmd 창을 오픈한다. kafka-console-producer 창이 된다.
kafak-console-producer.bat --broker-list localhost:9092 --topic hello-kafka 를 입력 후 엔터를 친다. 다음 행에서
> 이 뜬다. consumer 에게 보낼 message 를 입력한다. 실시간으로 해당 메시지가 consumer 에게 보내진다.
앞서 열었던 kafka-console-consumer 창에 send message 가 출력된다.
초기 설정값에서 한글은 지원하지 않는다.
참고자료(REFERENCES)