카프카 바인더가있는 스프링 클라우드 스트림과 소스에서 데이터를 대기열에 넣는 방법

Question

나는 kafka로 구름 구름을 봄으로써 그 개념에 대해 궁금해하는 초보자입니다. 내 응용 프로그램에서 소스가 kafka 바인더에 스트림을 보내면 데이터가 쌓이지 않습니다 ... 데이터 소스가 실제로 소비되지 않는 Kafka 소비자에서 작동하고 있음을 알 수 있습니다.

그러나 수신기에서 쌓인 데이터는 사용할 수 없습니다. (프로세서 수신기). 거의 실시간으로 소스에서 스트리밍 된 데이터 만 사용할 수 있습니다.

예를 들어 설명해 드리겠습니다. 생산자 용

data1, data2, data3, data4, data5, ... (streaming for producer) 

소비자의 경우 data4가 생성 될 때 시작됩니다. 그럼, 카프카, 데이터 1, 데이터 2, 데이터 3가 소비자를 기다리고해야의 개념을 알다시피 내 응용 프로그램은 ... 데이터 4에서

data4, data5, data6, .... (streaming for consumer) 

데이터를 얻을 것입니다하지만 나를 위해하지 않습니다. 내가 무엇을 잘못 알고 있고 이것을 해결할 생각이 있니?

Answer 1

구성을 표시해야합니다.

익명 사용자 (사용자가 spring.cloud.stream.bindings.xxx.group이없는 사용자)는 주제가 끝날 때부터 (시작될 때) 소비되기 시작하므로 일부 메시지를 "놓치기"쉽습니다.

group (소비하지 않은 소비자)이 처음부터 시작됩니다. group (이전에 소비 한 소비자)은 중단 한 부분부터 시작합니다.