Kafka3 [spring kafka] group id 관련 삽질 kafka consumer 팩토리에서 group id를 넣었는데 설정된 id값으로 groupId가 자동 설정이 되었다. KafkaListener 어노테이션 파라미터에 idIsGroup 옵션의 디폴트가 true여서 생겼던 문제였다. false로 설정해주면 정상적으로 팩토리에서 설정해준 groupId로 설정이 되는걸 볼 수 있다. 2023. 3. 5. [spring kafka] consumer @KafkaListener로 처리되는 스레드 이름 지정 id 프로퍼티를 주면 된다. 스레드 이름은 프로퍼티로 준 이름 기반으로 생성된다 2022. 12. 13. Kafka Consumer Retry를 위한 노력 대충 히스토리 설명 consumer에서 이벤트 받아서 처리하는 로직에 써드파티 api를 호출하는 부분이 있는데, 너무 빠르게 호출하는지 자꾸 Throttling Exception 을 뱉는다. 근데 이게 초당 요청을 몇으로 제한하라는 이런 가이드가 없어서, 실패시 retry 하는 방향으로 개선을 해보려고 한다 첫번째 시도 - retryTemplate batch listen(단건으로 말고 레코드 뭉탱이로 들고오는거)을 하고 있어서 retryTemplate 사용 불가능 batch records에서 몇번째 record인지 알 수가 없다고 한다. 실패 두번째 시도 - SeekToBatchErrorHandler 위에서 말했듯이 batch listen을 하고 있어서 여기저기 찾아보다가 스택오버플로보고 시도한 방법이다.. 2022. 6. 25. 이전 1 다음
