Kafka Topic, Producer, Consumer 생성하기

이번 글에서는 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를 받아보았다.

리눅스 환경에서만 하다가 윈도우로 설치해보니 너무 간단하고 편리하다.