問題タブ [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.
amazon-web-services - AWS Kinesis KCL は、起動前に追加されたレコードをスキップします
と の両方を使用してKPL
、KCL
サービス間でデータを交換するようになりました。ただしconsumer service
、 がオフラインになると、 から送信されたすべてのデータKPL
が永久に失われます。そのため、稼働中に送信されたデータのチャンクのみを取得consumer service
し、shardConsumer
準備ができています。最後に消費されたポイントから開始するか、何らかの形で残ったデータを処理する必要があります。
これが私のShardProcessor
コードです:
構成コード: