====== 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]]