[Kafka] Java 테스트 애플리케이션 제작 및 테스트

간단하게 kafka의 cluster 구성에 성공했는지 테스트하기 위해서 프로젝트를 생성해보겠습니다.

 

dependency는 kafka만 추가하셔도 됩니다.

@Slf4j로 로그 출력을 위해 Lombok도 추가했습니다.

 

application.yml에 카프카 설정을 추가합니다.

 

KafkaConfig.java로 자바 파일을 생성하여 상단에

@Configuration
@EnableKafka

카프카 설정을 위한 어노테이션을 추가합니다.

 

yml에 선언한 변수를 @Value로 받아옵니다.

 

ProducerConfig와 ConsumerConfig를 설정합니다.

 

추가한 설정을 Factory로 생성합니다.

 

테스트를 위해 Consumer 클래스를 생성했습니다.

 

이렇게 하면 테스트를 위한 애플리케이션 생성이 끝났습니다.

 

---

 

이제 이전에 설치한 CMAK(kafka manager에 접속하여 cluster를 생성하고, topic을 생성합니다.

이름은 간단히 CLUSTER_TEST로 생성했습니다.

 

kafka를 설치한 서버에 접속하여 bin 디렉터리 내에 kafka-console-producer로 메시지를 넣어보겠습니다.

 

$ ./kafka-console-producer.sh --broker-list {ip1}:9092, {ip2}:9092 --topic CLUSTER_TEST

$ 1, halfstorage
$ 2, halftest
$ 3, a
$ 4, b
$ 5, c
$ 6, d
$ 7, e

 

* console-producer key null에러 발생 시 참고: halfstorage.tistory.com/79

정상 처리를 확인 후 kafka 서버 하나를 종료 한 다음 추가로 메시지를 넣으면

아직 구동 중인 서버에서 처리하는 것을 확인할 수 있습니다.