Spring Boot에서 Kafka Topic이 Consume 안되는 현상 수정

Spring Boot 로컬 환경에서 Kafka Topic의 데이터가 Consume이 안되는 현상이 발생했습니다.

확인해보니 여러명이 개발하는 프로젝트의 Kafka Consumer의 group-id가 아래와 같이 application.yml 파일에 동일하게 설정되있어서 하나의 Consumer만 Consume이 가능 했었습니다.

spring:
    kafka:
        consumer:
        	group-id: group_local

 

개발자마다 group-id가 달라야 개별적으로 Consume이 가능하기 때문에 application.yml에 설정된 group-id를 @KafkaListener에 SpEL을 사용해서 PC명으로 설정하게 수정하니 정상적으로 Consume이 되었습니다.

@KafkaListener(topics = "test_topics", groupId = "#{ T(java.net.InetAddress).getLocalHost().getHostName() }")

 

 

참고자료

https://devfunny.tistory.com/757

https://junuuu.tistory.com/792