Enhanced Fan-Out + Consumer + Lambda

0

I have a Kinesis Data Stream with 3 shards: 0001, 0002 and 0003. I have registered a Consumer in the data stream. I have 2 shard subscriptions, one for consumer 1 and shard 0001, and the other for consumer 2 and shard 0002. I have 2 lambda functions, one has as a trigger the data stream with consumer 1, and the other has as a trigger the data stream with consumer 2. According https://docs.aws.amazon.com/streams/latest/dev/enhanced-consumers.html says: "If you use the API to build a consumer that uses enhanced fan-out, then you can subscribe to individual shards."

When the lambda functions run, they read records from all the shards, not the one that is assigned to the consumer. How I can use EFO + consumers + shard subscription + lambda function to read records from a particular shard?

Any clue?

  • Is there a specific reason to assign a specific shard to a lambda function?

질문됨 일 년 전131회 조회
답변 없음

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

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

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

관련 콘텐츠