KafkaConsumerとKafkaProducerのアイドル時間設定

Question

私たちのアプリケーションは長時間実行されており、停止/強制終了するまで実行する必要があります。そのための設定は、longのプロデューサとコンシューマの両方にconnections.max.idle.msを設定することです。無限に設定したり、閉じたりしないように設定する方法はありますか？

connections.max.idle.msを10分に設定すると、プロデューサは何も生成されないため、20分間アイドル状態になります。後でプロデューサーがメッセージを生成する必要があります。プロデューサーは自動的に目を覚ましますか？

Answer 1

プロデューサーがメッセージの再送信を開始した後、プロデューサーは自動的にKafkaブローカーを使用してチャンネルを再作成します。

connections.max.idle.msが期限切れになると、クライアントコードによってチャネルが閉じられ、リソースの使用が減少します。この動作を無効にするには、-1に設定します。