zookeeper-設定した時間後にメッセージを再送信

私の場合、コンシューマを作成し、メッセージを読み込んでエラスティックサーチに書き込みます。次に、私はそれらをコミットしない（オートコミットなし）。場合によっては、私がコミットしないように、書面による失敗があるかもしれません。 zookeeperを設定して一定時間後に送信されなかったmsgを再送信するオプションはありますか？zookeeper-設定した時間後にメッセージを再送信

出典

2016-06-19 Mattan Bitner

私は従うことができない...飼育係は「Distrubted Consesusサービス」であるとメッセージを送信することはありません....あなたもこの質問を「apache-kafka」とタグ付けしました。そこから消費者メッセージを受け取りますか？質問を編集して詳細を入力してください。 –

あなたがApacheのカフカを使用している場合、あなたのプロデューサーに再試行プロパティのコンフィグを変更することができます。http://kafka.apache.org/documentation.html#producerconfigs

出典

2016-06-19 15:20:41 MaximeF

はい、これはsendで失敗したケースではありません。コミットされていないメッセージのようなものは設定によってカバーされていません –

zookeeper-設定した時間後にメッセージを再送信

答えて

関連する問題