Kafka에서 서버연결해서 메세지보내기

이전 게시글 ‘AWS EC2에 Kafka 설치하기’의 다음 내용입니다.

서버1에서 서버2의 토픽을 만듭니다

/usr/local/kafka/bin/kafka-topics.sh \
--create \
--bootstrap-server kafka2:2181 \
--topic jjongguet2

서버2에서 console-consumer를 열어서 토픽을 받아들일 준비를 합니다

/usr/local/kafka/bin/kafka-console-consumer.sh \
--bootstrap-server kafka2:9092 \
--topic jjongguet2

이전에 존재하는 메세지가 존재한다면 --from-beginning 옵션을 써서
이전 데이터를 먼저 가져와도 무방합니다

서버1에서 console-producer를 열어서 토픽을 보낼준비를 합니다

/usr/local/kafka/bin/kafka-console-producer.sh \
--broker-list kafka2:9092 \
--topic jjongguet2

이후 쉘이 > 로 바뀌었다면, 메세지를 보냅니다.