java - 一个 @StreamListener 依赖于另一个 @StreamListener

Question

我有一个用例，我在 Kafka 中有 2 个主题，一个主题是 ABC，另一个主题是 CDE，CDE 中的主题数据用于计算并且它的大小并不大，所以我们想用这个数据，然后在计算中使用这个 Map 来自主题 ABC 的数据。因此，从第 1 步开始，当组件启动时，我想在使用来自 ABC 的任何消息之前用 CDE 中的所有数据填充 Map，并且在对从主题 ABC 接收的数据进行任何处理时，我将检查主题中是否有未消费的消息CDE 如果是，则更新缓存，并使用缓存结果。如何使用 Spring Cloud Stream 实现这一点

标签： javaspringspring-cloudspring-cloud-stream

Answer 1

spring-cloud-stream 确实不是这种情况。填满缓存是初始化/启动的责任，所以这不是如何用spring-cloud-stream实现的问题，而是如何实现的问题。我的意思是你当然可以使用 spring-cloud-stream 来破解一些东西，我只是说它不是设计用于监听器必须加载一些缓存的用例。