2017-10-04 17 views
1

나는이 정보를 온라인에서 쉽게 찾을 수 없다는 것이 이상하지만 나는 할 수 없다. 그래서, 제 질문은 제가 카프카 주제를 가지고 있다는 것입니다. 두 소비자 그룹이 서로 독립적으로이 주제의 메시지를 소비하길 바랍니다. 그래서 내가 원하는 것은 소비자 그룹이 서로 독립적으로 모든 메시지를보고 소비 할 수 있어야한다는 것입니다.카프 카 : 여러 독립 소비자 그룹이 주제를 소비 할 수 있습니까?

좀 더 명확히하기 위해 일부 소비자 그룹이 일부 메시지를 소비하지 말고 다른 그룹이 소비하는 메시지를 원하지 않습니다. 아니오, 두 그룹이 다른 그룹이 존재하지 않는 것처럼 메시지를 소비하기를 원합니다.

답변

1

예, 여러 소비자/소비자 그룹이 주제의 메시지를 독립적으로 소비 할 수 있습니다. 각 소비자 (또는 소비자 그룹)의 오프셋은 별도로 유지됩니다. 소비자가 주제에서 메시지를 읽을 시작되는 (오프셋 (offset)) 자동으로 제어되는

bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --topic test --zookeeper localhost:2181 --group testgroup 

주 : 아래 그림과 같이 당신은 어떤 주제에 대한 어떤 소비자 그룹에 대한 오프셋을 볼 수 kafka.tools.ConsumerOffsetChecker를 실행할 수 있습니다 .offset.reset 구성. 최소값으로 설정하면 새 소비자는 항목 시작 부분 (최소) 또는 주제 끝 부분 (최대로 설정된 경우)부터 시작합니다.

2

예, 개별 소비자 그룹은 완전히 독립적이므로 모두 모든 메시지를 볼 수 있습니다.

자원 (주제/파티션)의 분할은 그룹 내에서만 발생합니다.

+0

"자원 (주제/파티션)의 분할은 그룹 내에서만 이루어집니다"라는 말의 의미를 잘 모르겠습니다. 각 주제의 분할 및 복제는 소비자 그룹별로 변경할 수 없습니다. 이는 주제 자체를 작성할 때 결정됩니다. – user1888243

+0

나는 하나의 소비자 만이 파티션에 할당 될 수 있기 때문에 하나의 그룹에서 소비자에게 파티션을 할당하는 것을 의미했습니다. –