問題タブ [amazon-kinesis-kpl]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票する
1 に答える
227 参照

amazon-web-services - AWS Kinesis KCL は、起動前に追加されたレコードをスキップします

と の両方を使用してKPLKCLサービス間でデータを交換するようになりました。ただしconsumer service、 がオフラインになると、 から送信されたすべてのデータKPLが永久に失われます。そのため、稼働中に送信されたデータのチャンクのみを取得consumer serviceし、shardConsumer準備ができています。最後に消費されたポイントから開始するか、何らかの形で残ったデータを処理する必要があります。

これが私のShardProcessorコードです:

構成コード: