이번 글에서는 Topic, Producer를 생성하여 Message를 보내고, Consumer를 생성하여 Message를 받아보겠다.
1. Topic 생성 및 Message 발행하기
1) Topic 생성
다음과 같은 명령어로 Topic을 생성한다.
토픽 명 tp-song으로 새로운 topic을 생성했다. topic명은 아무거나 입력해도 상관없다.
장비가 1대이기 때문에 replication-factor와 partitions를 1로 설정했다.
.\kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic [토픽명]
토픽을 정상적으로 생성하면 Created topic [토픽명] 메시지를 확인할 수 있다.
2) Topic 리스트 확인
생성된 Topic들의 목록을 확인한다. (굳이 하지 않아도 됨. 그냥 확인 작업)
.\kafka-topics.bat --list bootstrap-server localhost:9092
명렁어를 실행하면 생성된 Topic 의 목록을 볼 수 있다. 현재 하나 생성했으므로 tp-song 하나만 보인다.
2. Producer 생성하기
다음과 같은 명령어로 Producer를 생성한다.
.\kafka-console-producer.bat --broker-list localhost:9092 --topic [토픽명]
만들어둔 Topic으로 Message를 발행한다.
명령어를 입력하면 > 표시가 나오는데, 원하는 Message를 보내면 된다.
Message입력을 마치면, Ctrl+c, y를 눌러 작업을 종료한다.
3. Consumer 생성 및 Message 수신하기
다음과 같은 명령어로 Consumer를 생성한다.
.\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic [토픽명] --from-beginning
간단하게 Topic, Producer를 생성하여 Message를 보내고, Consumer를 생성하여 Message를 받아보았다.
리눅스 환경에서만 하다가 윈도우로 설치해보니 너무 간단하고 편리하다.
'Kafka' 카테고리의 다른 글
Kafka! 실시간으로 Message 처리하기! (Java) (0) | 2020.07.19 |
---|---|
Kafka Consumer를 생성하여 Message를 받아보자! (Java) (0) | 2020.07.19 |
Kafka Producer를 생성하여 Message를 보내보자! (Java) (0) | 2020.07.19 |
IntelliJ Kafka 개발환경 구축하기! (0) | 2020.07.18 |
Kafka 1분만에 설치하기 (window) (0) | 2020.07.18 |