자동 커밋을 할 수있는 동안 수동으로 파티션을 할당하는 방법은 무엇입니까?

Question

소비자 그룹 내의 각 소비자에게 파티션을 수동으로 할당하려고합니다. 그룹에 소비자를 추가하는 것처럼 보이지만 Kafka (또는 적어도 kafka-python)는 그룹 코디네이터가 모든 과제를 수행하기를 원한다고 가정합니다. 파티션 할당을 수동으로 관리 할 수있는 동안 소비자 그룹 (특히 자동 커밋) 사용의 모든 이점을 계속 유지할 수있는 방법이 있습니까? 사용자 정의 파티션 할당기를 작성할 수 있습니까?

저는 kafka-python 1.3.3 라이브러리를 사용하고 있습니다.

Answer 1

예, 카프카 소비자는 속성이 "enable.auto.commit"

를 구동하면, 기본 RangeAssignor

자동 커밋

이다 자신 만의 양도인을 지정할 수 있습니다 속성 "partition.assignment.strategy"을 가지고

카프카 소비자 구성 : https://kafka.apache.org/documentation/#consumerconfigs