권남

이 문서는 읽기 전용입니다. 원본을 볼 수는 있지만 바꿀 수는 없습니다. 문제가 있다고 생각하면 관리자에게 문의하세요.

====== SpringFramework Kafka ======
  * [[:springframework|Spring Framework]] 과 [[:kafka|Kafka]]
  * [[https://docs.spring.io/spring-kafka/reference/html/|Spring for Apache Kafka]]
  * 

===== Kafka Listener Concurrency =====
  * ''@KafkaListener'' 에 ''concurrency''
  * **한 리스너당** Kafka 파티션 갯수보다 많은 ''concurrency''를 지정해도 무의미하다. 최대 파티션 갯수만큼만 동시 처리한다.
  * ''concurrency'' 를 파티션 갯수보다 적게 세팅하면 적게 동시 처리한다.
  * [[https://www.baeldung.com/spring-kafka-multiple-listeners-same-topic|Spring Kafka: Configure Multiple Listeners on Same Topic | Baeldung]]
  * 동일 ''groupId'' 로 여러개의 리스너를 만들면 리스너 갯수만큼 동시성이 확장된다.

===== 참조 =====
  * [[https://howtodoinjava.com/kafka/multiple-consumers-example/|Spring Boot Kafka Multiple Consumers Example]]

권남

사용자 도구

사이트 도구

문서 도구