kafka를 사용하는 양방향 메시징 시스템

Question

apache kafka를 사용하여 양방향 메시징 시스템을 개발할 수 있습니까? 내 소비자로부터 메시지를 보내야 할뿐만 아니라 내 소비자로부터 주제를 구독해야합니다.

Answer 1

두 가지 방법 중 하나를 사용할 수 있습니다. 메시지 키의 접두사 시스템을 설정하거나 소비자가 생성 한 메시지를 피할 수있게하는 메시지 내부에 내용을 넣으십시오.

이제 메시지 트래픽에 따라 디자인해야하는지 여부를 결정하십시오. 이벤트로 슬래 밍하지 않는 경우 메시지 구성 요소가 양방향 통신을 수행하는 방법으로 Thrift를 고려하는 것이 좋습니다. 카프카가 복잡성에 비해 탁월한 점은 엄청난 양의 데이터를 생산하고 소비해야 할 때입니다. 그게 당신에게 해당되지 않을 수도 있습니다.

예를 들어 Kafka의 일반적인 사용 사례는 수백 또는 수백 TB의 데이터를 분산 처리하기 위해 Storm, Apex 또는 Samza와 같은 서비스에 연결하는 것입니다. 시스템의 처리량 요구 사항이 높으면이 아키텍처는 카프카가 메시지를 처리하기위한 출발점으로 고려하는 것이 좋습니다. Storm을 사용하면 재 처리를 위해 메시지를 다시 보내야하는 경우 Kafka 볼트를 사용하여 메시지를 다시 카프카에 다시 게시하여 완전히 재 처리되도록 할 수 있습니다.