Kafka 메시지에 워크 플로우를 추가하는 방법은 무엇입니까?

Question

내 Java 프로젝트를 Rabbit MQ에서 Kafka로 마이그레이션 중입니다 (이유가있을 수 있음).

그러나 나는 한 가지 어려움에 직면하고 있습니다.

현재 워크 플로우에서 모든 메시지를 토끼 mq 교환에 게시하고 메시지의 라우팅 키에 따라 메시지가 하나 이상의 대기열로 리디렉션됩니다. 카프카에서도 같은 기능을 유지하고 싶습니다. (나는 kafka가 원래 그것을 위해 적당하지 않다는 것을 안다. 그러나 나는 workaround를 원한다).

기본적으로 나는 다음과 같이 원합니다. 메시지에있는 메타를 기반으로 메시지가 주제별로 수신 될 때마다 메시지를 다른 주제 세트로 리디렉션해야합니다.

가장 빠른 방법은 무엇입니까? 모든 유사한 키가 동일한 파티션으로 이동하도록 그들이 주제 파티션로 이동합니다 키 카프카 메시지를 게시하면 내가 파이썬이나 자바 솔루션을

감사

Answer 1

을 선호 할 것입니다.

또는 카프카 스트림을 사용하여 입력 토픽을 읽고 메시지와 함께 제공된 키를 기반으로 출력 항목 집합으로 메시지를 라우팅 할 수 있습니다.