카프카 0.8이 메시지 레벨로드 밸런스를 달성하는 방법은 무엇입니까?

Question

우리는 카프카 0.8에서 생산자가 사육사와 연결하지 않고 브로커에 직접 연결한다는 것을 알고 있습니다. 요구 사항에 따라 사육사 기반로드 균형을 달성하는 방법보다? 사실, 주제가 작성되면 그 파티션은 하나 이상의 브로커에서 분배됩니다. 메시지를 보내면 해당 키워드에 따라 특정 파티션으로 전달됩니다. 즉, 특정 브로커의 고정 파티션으로 전송해야합니다. 소위로드 밸런싱은 어떻게 작동합니까?

Answer 1

프로듀서 끝의로드 균형 조정은 브로커가 사용이 제공된 키를 기반으로 자동으로 분할되도록할지 또는 브로커가 메시지가 자동으로 이동하는 파티션을 처리하도록할지 여부에 따라 효과적으로 결정됩니다.

에이 없으면 파티션 키를 지정하지 않아도되므로로드 균형 조정은 파티션과 달리 주어진 주제에서 사용 가능한 파티션 수로 제한됩니다 키에 할당됩니다.

Answer 2

kafka는 브로커에 연결하기 위해 Zookeepeer 인스턴스가 필요합니다. 기본 파티셔너 또는 커스텀 파티셔너를 사용하여 주제의 partitons에 작성하여로드 밸런싱을 달성 할 수 있습니다.