session.timeout.mx
-
[Kafka] - 10. Consumer_Rebalance개발/Kafka 2022. 8. 9. 14:51
Partition-Assignment 하나의 Partition은 지정된 Consumer_group 내에 하나의 Consumer만 사용 가능 동일한 Key를 가진 Message는 동일한 Consumer가 사용한다. Consumer의 설정 Parameter 중 Partition.assignment.strategy로 할당 방식을 변경이 가능하다. Consumer Group은 Group Coordinator 프로세스에 의해 관리 된다. Partition.Assignment.Strategy org.apache.kafka.clients.consumer.RangeAssginor : Topic별로 작동하는 Default Assignor org.apache.kafka.clients.consumer.RoundRobinAs..