問題タブ [amazon-kcl]
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.
docker - Docker で AWS KCL キャプチャ シャットダウン シグナル
./bin/kcl-bootstrap -p app.properties -j /usr/bin/java -e端末と同じようにKCL を実行したとき、実行しps -ef | grep javaて pid を取得しました。発行しkill -s TERM $PID_ABOVEました。ノード recordProcessor がこのようにログに記録されていることに気付きました
2018-03-31T11:13:46.998 INFO recordProcessor - Shutdown requested
2018-03-31T11:13:48.024 INFO recordProcessor - Shutting down...
docker run コマンドなどを使用して同等のコマンドを実行した
場合、 orまたはをdocker run -v /tmp:/tmp -v ~/.aws:/root/.aws -ti cde3946e2cf9発行して docker を終了しても、上記のログは生成されませんでした。たとえば、recordProcessor はシャットダウン要求について通知を受けませんでした。Ctrl-Cdocker stop cde3946e2cf9docker kill --signal=SIGTERM cde3946e2cf9
Docker は Kubernetes クラスターにデプロイされています。Docker を再デプロイするとProcess terminanted, will initiate shutdown.、メイン プロセッサによってログに記録されていることがわかりますが、ワーカー シャットダウン リクエストからは何も報告されていません。
docker を再デプロイするときにこれらのイベントをトラップして、シャットダウンを適切に処理できるようにしたいと考えています。
クラスターにドッカーを再デプロイするときに、ワーカーが確実に通知を受けるようにする方法を知っている人はいますか?
ありがとう
amazon-kinesis - KCL 1 つの ProcessRecordsInput のレコード数を知る方法は?
KCL を使用して Java で記述された Kinesis コンシューマがあります。コンシューマー側からは、setMaxRecords メソッドを使用してレートを調整し、1 つのバッチ内のレコード数の上限を設定できます。
私の質問は、制限を設定しない場合、1 つのバッチに含まれるレコードの数を決定するロジックは何ですか? 許可される最大値のデフォルト値はありますか?