私のテストケース。
私はコンシューマーを持っていno_ack =>0ますprefetch_count。 がデフォルトです。前のメッセージが確認されていない場合でも、コンシューマはメッセージを受信します。
メッセージが確認されないか、ackメッセージが転送中に失われ、コンシューマがダウンしない場合、このメッセージは確認されず、他のコンシューマに送信されません。永遠に列に並んでいます。
メッセージをタイムアウトさせたくありません。代わりに、指定されたタイムアウトが同じコンシューマーに送信された後にメッセージを再送信する必要があります。
これを行う方法はありますか？
ありがとう