카프카와 주키퍼를 설치해보자 feat 우분투 3탄

자 먼저 각 서버에 모두 주키퍼를 먼저 실행하고 카프카를 실행해준다.

그리고 1번서버에서 테스트할 토픽을 하나 생성해준다.

#/root/kafka/bin/kafka-topics.sh --zookeeper kafka1:2181,kafka2:2181,kafka3:2181 --replication-factor 1 --partitions 1 --topic topicTest --create

topicTest라는 토픽을 1,2,3번 서버에 만들었다..

이제 토픽에 메세지를 날려보자...1번서버에서 한다.

#/root/kafka/bin/kafka-console-producer.sh --broker-list kafka1:9092,kafka2:9092,kafka3:9092 --topic topicTest

이렇게 실행하면 아래와 같은 콘솔이 뜬다. 여기에 메세지를 저장한다.

>test1

>test2

나올땐 CTRL+C를 눌러서 나온다.

이제 토픽에 등록한 메세지를 확인해볼 차례다...

#/root/kafka/bin/kafka-console-consumer.sh --bootstrap-server kafka1:9092,kafka2:9092,kafka3:9092 --topic topicTest --from-beginning

이렇게 명령을 날리면 

test1

test2

이렇게 화면에 나타난다...

이제 2번서버에 가서 메세지를 확인해보기위해 위와 똑같이 명령을 날린다...

#/root/kafka/bin/kafka-console-consumer.sh --bootstrap-server kafka1:9092,kafka2:9092,kafka3:9092 --topic topicTest --from-beginning

3번서버에서도 해보자...

#/root/kafka/bin/kafka-console-consumer.sh --bootstrap-server kafka1:9092,kafka2:9092,kafka3:9092 --topic topicTest --from-beginning

위와같이 했을때 모두 똑같은 메세지를 볼 수 있다면 제대로 설치한것이다.

안보인다면 설치를 잘못한거다. 다시 해보자....ㅠㅠ

끝.