0
스트리밍 모드의 메시지를 처리하는 "주제 A"에서 "구독 A"에 가입 한 데이터 흐름 프로세스가 있습니다.데이터 흐름 프로세스가 다시 시작한 후에 대기중인 메시지를 검색하지 않습니다.
PubSub 설명서에 따르면 메시지를 가져 오지 않으면 구독 당 최소 7 일간 메시지가 보관됩니다. 데이터 흐름 프로세스를 한 시간 동안 중지했다가 다시 시작하면 스트리밍 메시지를 진행하기 전에 구독자 프로세스가 다운 된 동안 구독에 누적 된 모든 메시지를 처리해야한다고 가정하는 것이 맞습니까?
데이터 흐름 프로세스가 다시 시작한 후 대기중인 메시지를 선택하지 않는 것 같습니다. 우리가 누락 된 명시 적 구성 옵션이 있습니까?
전제 조건이 맞으면 Dataflow가 이러한 중단 시간을 투명하게 처리하고 파이프 라인을 다시 시작할 때 모든 백 로그를 처리해야합니다. Dataflow가 대기중인 메시지를 처리하지 못했음을 감지하는 방법에 대해 자세히 설명해 주시겠습니까? 작업 ID가 도움이됩니다. – jkff
또한 한 시간 동안 파이프 라인을 중단한다고 말했기 때문에 파이프 라인 업데이트 기능 (https://cloud.google.com/dataflow/pipelines/updating-a-pipeline)에 관심이 있는지 궁금합니다. – jkff
주제 또는 구독 정보를 읽으십니까? 항목을 지정하면 데이터 흐름은 작업이 시작될 때 새로운 구독을 만듭니다.이 경우 버퍼링 된 메시지가 없습니다 (메시지는 구독마다 유지됩니다). –