Spring Cloud Streamを使用する前に、Spring-Kafkaとバッチ消費とカスタムエラー処理をサポートしていました。Spring Cloud Streamでのバッチモードとカスタムエラー処理
ただし、Spring Cloud Streamの設定方法はわかりません。私はこれらの構成プロパティを見つけることができます。
spring.cloud.stream.kafka.bindings.input.consumer.autoCommitOffset、enableDlq
したがって、それは(それがだろう)が可能に登録しますカスタムエラーハンドラを作成し、AckModeをSpring Cloud StreamのBATCHに設定しますか?
ご協力いただきありがとうございます。