2017-03-29 12 views
0

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に設定しますか?

ご協力いただきありがとうございます。

答えて

関連する問題