使用Spring Cloud Stream和Kafka处理错误

9gm1akwq  于 2023-08-02  发布在  Apache
关注(0)|答案(1)|浏览(105)

在带有Sping Boot 3的Spring Cloud流的4.0.x版本中,与SCS的3.2.0版本相比,通过绑定中的commonErrorHandlerBeanName属性处理错误的方式似乎已经改变。
但是,对于Spring Cloud Stream版本4.0.x,使用Consumer属性中的commonErrorHandlerBeanName属性进行错误处理仍然可以正常工作,尽管这种形式的错误处理不再出现在最新版本SCS的文档中,并且在代码级别不再被弃用。
对于未来版本,在SCS中处理错误的适当方法是什么?两者之间的区别是什么?

t98cgbkg

t98cgbkg1#

这两种错误处理机制都应该起作用。而您提到的来自4.0.x的新错误处理是作为一种通用错误处理技术添加的,与底层绑定无关。使用Kafka binder,您仍然可以灵活地(根据您的用例更合适)使用commonErrorHandlerBeanName。后一种方法在Kafka binder中并没有被弃用,将来也没有任何计划这样做。

相关问题