kafka consumer 팩토리에서 group id를 넣었는데 설정된 id값으로 groupId가 자동 설정이 되었다.
KafkaListener 어노테이션 파라미터에 idIsGroup 옵션의 디폴트가 true여서 생겼던 문제였다.
false로 설정해주면 정상적으로 팩토리에서 설정해준 groupId로 설정이 되는걸 볼 수 있다.
'Kafka' 카테고리의 다른 글
[spring kafka] consumer @KafkaListener로 처리되는 스레드 이름 지정 (0) | 2022.12.13 |
---|---|
Kafka Consumer Retry를 위한 노력 (0) | 2022.06.25 |