然后,此消息/事件将保存到数据库中。 对于Kafka监听器,我使用了Spring Cloud Stream。我读了Spring Cloud Stream documentation (for 3.0.0 release),他们说 Native support for reactive programming- since v3.0.0 we no longer distribute spring-cloud-stream-reactive modules and instead
在我的请求处理程序中,如果传入的accountId不能转换为有效的ObjectId,我希望捕获错误并发送回一条有意义的消息;然而,这样做会导致返回类型不兼容,并且我不知道如何实现这个相当简单的用例。This seems to be currently
// impossible with the Reactive API, as using body(message) changes我也尝试过使用onErrorXxxx()方法,但它们在这里也不起作用,因为转换错误甚至在计算通量之前就发生了,并且我只得到了一个带有空<em