[Kafka] Maven project 로 Producer와 Consumer 작성해보기

오늘은 윈도우에서 Maven project를 이용해 실습해본 kafka에 대하여 글을 정리해보겠습니다 !

우선 kafka에서 zookeeper 한대에 broker 3개를 세팅해놨고, kafka-manager에서 모니터링 할 수 있도록 추가 해주었습니다.

 

이클립스에서 maven project를 하나 열어줍니다

Consumer 클래스 하나, Producer 클래스 하나를 생성해주었습니다. 

 

의존성 추가

pom.xml을 열어서 위와 같은 kafka dependency를 추가해주었습니다. 

<dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>1.1.0</version> </dependency> <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-streams</artifactId> <version>1.1.0</version> </dependency> <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka_2.11</artifactId> <version>0.8.2.1</version> </dependency>

 

Consumer 작성

consumer 클래스를 먼저 실행해줍니다. 그 후에 producer 에서 message를 보내면 consumer의 콘솔창에 message가 나타나게 됩니다.

 

Producer 작성

 

producer 클래스를 실행시켜주면

위와 같은 결과가 consumer 콘솔창에 나타나게 됩니당

 

kafka manager 창에서도 설정한 topic에 메시지가 들어온것을 확인할 수 있습니다 !