how to add consumer to existing kinesis stream from java MS?


I need to add new consumer to an existing stream. I'm stuck on a point where I'm getting both shards of the stream correct but without data. when I'm iterating on them (with many retries and sleeps between) I don't see any records. (they exist because other consumer of the same stream get them). what configuration is needed to see data? plus, data viewer tab doesn't show the records (using LATEST) . why?

질문됨 일 년 전360회 조회
1개 답변


If you're using 'LATEST' iterator type, the consumer starts reading new data records from the most recent point onwards and does not read the data records written prior to it. For reading older data, you may consider using a 'TRIM_HORIZON' shard iterator type, which starts reading the oldest data record in the shard.

The above also holds true when using 'Data viewer' in Kinesis Streams via AWS Console.


지원 엔지니어
답변함 일 년 전

로그인하지 않았습니다. 로그인해야 답변을 게시할 수 있습니다.

좋은 답변은 질문에 명확하게 답하고 건설적인 피드백을 제공하며 질문자의 전문적인 성장을 장려합니다.

질문 답변하기에 대한 가이드라인

관련 콘텐츠