group id 질문입니다

Question

group id 옵션 설정하게 되면 consumer group 이 지정되어, 컨슈머가 토픽의 파티션을 구독하는 형태로 지정이 된다고 이해하고 있습니다. Assignor 가 (2.5.0기준 RangeAssignor) 해당 컨슈머 그룹에 구독되는걸 설정해 주는건지가 궁금합니다. 컨슈머 그룹 운영시에 Assignor 가 설정한다면 assign() 함수로 할당을 하게 된다면 어떻게 할당되는지도 궁금합니다. Assignor 가 동작을 하지 않고 개발자가 직접 할당하는 것인지... 정리하자면 GroupId 를 사용하는 컨슈머 그룹에 대한 구독 대한 설명과 Assing() 함수를 통하여 컨슈머를 할당하는 것에 대한 차이가 어떻게 되는것인지 입니다

데브원영 DVWY · Answer

MoonSang님, assign() 함수를 사용하시면 컨슈머 그룹에서 동작하는 방식과 다르게 운영됩니다. 그러므로 Assignor랑 무관하게 할당됩니다. 자세한 내용은 아래 공식문서를 참고해주세요. Manual partition assignment does not use group coordination, so consumer failures will not cause assigned partitions to be rebalanced. Each consumer acts independently even if it shares a groupId with another consumer. To avoid offset commit conflicts, you should usually ensure that the groupId is unique for each consumer instance. ㄴ KafkaConsumer 설명(링크)