2014-04-29 2 views
0

메시지를 소비하는 동안 문제가 발생했습니다. 나는 5 명의 브로커와 4 개의 복제본이있는 5 개의 파티션을 가지고 있습니다. 나는 3 명의 소비자를 생성하고 사육사와 연결하여 메시지를 소비하려고합니다. 그러나 나는 모든 메시지를 단일 소비자에게 전하고 메시지를 소비자에게 전가시키지 않고 있습니다. 몇 가지 제안 사항을 보내주십시오.카프카 + 사육사

+0

당신이 코드 예제를 줄 수 있습니까? 속성을 어떻게 설정 했습니까? – gaganbm

답변

3

[...] 주제 내에서 파티션과 같은 병렬 개념을 사용함으로써 카프카는 소비자 프로세스 풀에 대해 주문 보증과로드 밸런싱을 모두 제공 할 수 있습니다. 이 작업은 주제의 파티션을 소비자 그룹의 소비자에게 할당하여 각 파티션이 그룹의 정확히 한 소비자에 의해 소비되도록합니다. [...]

CF : 어떻게 3 개 소비자를 창조 하셨 는가에 https://kafka.apache.org/documentation.html#intro_consumers