리눅스(Linux)에서 카프카(Kafka) 설치 및 간단 테스트하기

카프카(Kafka)를 리눅스(Linux)에 설치하고 실행해 보겠습니다.

관련 이전 포스트:

* 자바(Java) 1.8 이상이 필요합니다.
  • 카프카를 공식홈페이지에서 다운로드 받습니다. (저는 cURL을 사용해서 다운로드 받았습니다.) 
curl을 사용하여 카프카 다운로드
  • tar -xzf 로 압축을 해제합니다. 
리눅스에서 카프카 압축해제 하기
  • 폴더를 확인합니다. 
  • 주키퍼(Zookeeper)를 백그라운드에서 실행합니다. bin/zookeeper-server-start.sh -daemon config/zookeeper.properties (항상 주키퍼를 먼저 실행합니다.)
리눅스에서 주키퍼 백그라운드에서 실행
  • netstat -ntlp로 잘 실행됐는지 확인합니다. (주키퍼 default 포트는 2181입니다.)
주키퍼(zookeeper) 디폴트(default) 포트는 2181
  • 카프카를 백그라운드에서 실행하고 확인합니다. bin/kafka-server-start.sh -daemon config/server.properties (카프카 default 포트는 9092입니다.)
리눅스에서 카프카 백그라운드 모드로 실행
  • bin 폴더 안에 kafka-topics.shtest란 토픽을 만듭니다.  ./kafka-topics.sh --create --bootstrap-server localhost:9092 --topic test
리눅스에 카프카 토픽 생성하기
  • --list 옵션을 사용해서 test 토픽이 생성됐는지 확인합니다. ./kafka-topics.sh --list --bootstrap-server localhost:9092 
리눅스에 카프카 토픽 리스트하기
  • kafka-console-producer.sh을 사용하여 test토픽에 메세지를 넣습니다. ./kafka-console-producer.sh  --broker-list localhost:9092 --topic test
리눅스에서 프로듀서로 카프카에 메세지 넣기
  • 컨트롤 + c로 나온 뒤, kafka-console-consumer.sh을 사용하여 test 토픽에 있는 메세지를 가져오는지 확인합니다. ./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
리눅스에서 카프카 컨수머 테스트

Comments