자바(Java)로 Kafka Producer와 Consumer 구현하기

이클립스(Eclipse)에서 자바로 기본적인 프로듀서(producer)와 컨수머(consumer)를 구현해 보도록 하겠습니다. 

관련 이전 포스트 : 

1. 윈도우에서 카프카 설치하기 (click)

2. 이클립스 설치하기 (click)

• 이클립스에서 카프카 라이브러리를 추가합니다. 윈도우에 카프카를 설치한 경우 libs 폴더 안에 있는 jar 파일을 추가하면 됩니다. 

• 추가하셨으면 Referenced Libraries에 나타납니다.

• 프로젝트를 생성하고 producer 클래스와 consumer 클래스를 만듭니다.

• 아래의 producer 코드를 복사하여 실행합니다.
• 0부터 9999까지 데이터 만 건이 카프카 test-clients 토픽에 들어갑니다. 

• 아래의 consumer 코드를 복사하여 실행합니다. 
• 이클립스 콘솔창에서  test-clients토픽으로부터 가져온 데이터를 확인하실 수 있습니다. 

* producer와 consumer의 자세한 내용은 나중에 포스트 할 예정입니다. 

** 코드는 막 쓰시면 됩니다.