선택기가있는 Apache Kafka 클라이언트?

Question

Apache Kafka를 조사 중이며 클라이언트가 메시지를 필터링 할 수 있어야하고 필터링이 클라이언트가 아닌 브로커에서 이루어져야합니다. 이 요구 사항은 JMS 선택기를 사용하는 것과 동일합니다.

카프카에 셀렉터가없고, 필터링이 클라이언트에서 이루어 졌다는 것이 제 생각에는 잘못된 것 같습니다. 따라서 모든 메시지는 클라이언트로 보내지고 클라이언트는 필터를 담당합니다.

브로커에서 필터링이 발생하는 JMS Selector 방식을 구현하는 방법이 있습니까?

Answer 1

아니요, 그렇게 할 수 없습니다. 당신이 할 수있는 최선은 클라이언트 측에서 필터링하는 것입니다. Apache Kafka API는 "오프셋 X에서 시작하는 주제 N 파티션 M에 대해 최대 1MB의 메시지를 제공합니다."와 같은 종류의 페칭 만 지원합니다.

Wire Protocol reference을 참조하면 가져 오기 요청에 대한 가능한 옵션을 볼 수 있지만 찾고있는 것이 없습니다.

실제로, 모든 가져 오기가 순차적 읽기이기 때문에 Kafka가 빠르기 때문에 향후 릴리스에서는 구현되지 않을 것이라고 생각합니다.하지만 내가 잘못하면 기뻐할 것입니다. :)).