处理kafka streams和spring cloud stream的事务

ibps3vxo  于 2021-06-06  发布在  Kafka
关注(0)|答案(0)|浏览(280)

我正在开发一个基于kafka和kafka流的应用程序(基于微服务)。我使用的是springboot和springcloudstream,我在处理kafka streams操作的事务时遇到了问题。我知道纯粹用kafka消费者处理事务没有问题,但是当我尝试在中间添加kafka流处理时,它对我来说变得很棘手。
例如:
在我的一个服务中,产品的订单请求来自主题a。
库存信息来自主题b
此服务生成主题b的库存更新,但它还负责发布有关准备装运的产品的事件(到主题c)
当收到主题a的订单请求时,我想检查(通过处理主题b)特定产品的库存是否充足,并向主题c发布一个成功或失败的事件(关于该订单)。
同时,我需要更新库存(减去为装运预留的数量),以便下一个订单有主题b中的实际值。我想将成功发布到主题c,并在一个事务中更新主题b上的清单。
在Spring的云溪里有Kafka溪吗?如果是的话,我怎么能做到呢?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题