spring
2021. 7. 13.
Spring-Kafka에서 읽은 Record 개수 알기
카프카를 사용하면서 내가 실질적으로 consume한 record가 몇 개인지 알아야 했다. max.poll.records = 300 // default 500 물론 위와 같은 설정으로 Kafka consumer가 broker로부터 consume한 record을 컨트롤할 수 있지만 이는 프로퍼티 이름에서 볼 수 있듯이 maximum을 제한할 뿐... 내가 원하던 기능은 실제로 consume한 record의 개수를 알아야 했다. 위와 같은 설정에서도 실제 consume한 record의 개수는 100, 150, 200 일수도 있으니깐. spring-kafka을 사용하지 않았으면 아주 간단하게 해결 가능했는데, spring-kafka을 사용하면서 뭔가 복잡해진 것 같은 느낌이 들지만 그래도 RetryTempla..
