我正在使用 aws sdk。Kinesis 数据流。我遇到以下问题。 1. "SubscribeToShard" 调用只在订阅后调用一次回调。 步骤: 1.Registered to Stream 2.订阅分片并期望它在流中有消息时给我打电话(对于同一个分片)。问题:aws 是自动回拨我注册的回拨,还是只回拨一次。
2.消费者从stearm获取数据,我希望数据在我消费后被清除。我是否需要设置任何标签,以便使用的数据从流/分片中消失。
我正在使用 aws sdk。Kinesis 数据流。我遇到以下问题。 1. "SubscribeToShard" 调用只在订阅后调用一次回调。 步骤: 1.Registered to Stream 2.订阅分片并期望它在流中有消息时给我打电话(对于同一个分片)。问题:aws 是自动回拨我注册的回拨,还是只回拨一次。
2.消费者从stearm获取数据,我希望数据在我消费后被清除。我是否需要设置任何标签,以便使用的数据从流/分片中消失。