私の場合、コンシューマを作成し、メッセージを読み込んでエラスティックサーチに書き込みます。次に、私はそれらをコミットしない(オートコミットなし)。 場合によっては、私がコミットしないように、書面による失敗があるかもしれません。 zookeeperを設定して一定時間後に送信されなかったmsgを再送信するオプションはありますか?zookeeper-設定した時間後にメッセージを再送信
0
A
答えて
0
あなたがApacheのカフカを使用している場合、あなたのプロデューサーに再試行プロパティのコンフィグを変更することができます。http://kafka.apache.org/documentation.html#producerconfigs
+0
はい、これはsendで失敗したケースではありません。コミットされていないメッセージのようなものは設定によってカバーされていません –
関連する問題
- 1. Akkaアクターの再起動時に "init"メッセージを再送信
- 2. 一定時間後にchat_idを使用してTelegramボットのクライアントにメッセージを送信できますか?
- 3. Android XMPP - アイドルモードの1時間後にメッセージを受信しない
- 4. symfony 3:フォームを送信した後に値を設定
- 5. 特定の時間の後に送信されたSMSを取得する
- 6. トレイアイコンのコンテキストメニューを左クリックした後に送信されたメッセージ
- 7. 送信後の応答メッセージ
- 8. メッセージをアンドロイドウェアに送信するアンドロイドデバイスにメッセージを送信しますが、着信時に受信したメッセージは受信されません。
- 9. エラーの取得:エラー:送信後にヘッダーを設定できません。ページを再レンダリングした後
- 10. メールをsmtpで送信した後にメッセージを表示
- 11. ダウンロードするファイルを送信した後にメッセージを表示
- 12. メールを送信した後にメッセージIDを取得する
- 13. データを入力した後にメッセージを送信
- 14. gatlingによって送信されたメッセージにjmsタイプを設定します。
- 15. Linux:ユーザーログイン時にメッセージを送信
- 16. 設定した時間後にスクリプトを停止する
- 17. フォームを送信した後に選択した値を設定するには
- 18. AWS SQS送信者がメッセージを消費者に提供できる時間を設定する
- 19. 3回の再試行後にZooKeeperが失敗しました
- 20. Google APPスクリプト - >指定した時間が経過した後にGoogleフォームを強制的に送信する
- 21. セロリが時間を設定してもcrontabタスクを送信しない
- 22. 設定時間後に表示スパンクラス
- 23. 選択したIpsにメッセージを送信
- 24. ページを閉じた後にnode.jsにメッセージを送信する
- 25. チャットプログラムでメッセージを送信したクライアントにメッセージが送信されています
- 26. 最後のスパーク送信完了(または失敗)+ xxx時間後にスピンダウン
- 27. タイマー - 特定の時間が経過した後にメッセージを表示
- 28. アクションケーブルで特定の時間後にクライアントにメッセージをブロードキャスト
- 29. 応答時間が再設定されました
- 30. Djangoはユーザー登録後6時間後にメールとSMSを送信します
私は従うことができない...飼育係は「Distrubted Consesusサービス」であるとメッセージを送信することはありません....あなたもこの質問を「apache-kafka」とタグ付けしました。そこから消費者メッセージを受け取りますか?質問を編集して詳細を入力してください。 –