java - 使用Spring Cloud Stream阅读主题中的所有消息

Question

对于Spring-cloud-stream（使用Kafka），我几乎没有疑问。


Spring Cloud Stream是否有任何写方法可以遍历主题中所有消息的使用者？ [这基本上是出于某种验证目的所必需的，这样就不会将重复的消息写入kafka队列中]，并且，
像spring-kafka一样，Spring云流中的Future / sync支持又如何呢？


如果有人遇到过任何此类情况，那么您能否提供一些有关如何实现它们的详细信息。或者我必须与spring-cloud-stream并行使用spring-kafka（通过spring-kafka完成）依赖项来实现。

如果有任何工作代码或网址，请提供。这将非常有帮助。

提前致谢

Answer 1

对于您的问题，我还是有些疑惑，但是正如供您参考，Spring-cloud-stream-binder-kafka（我想您指的是）依赖于spring-kafka，并实质上扩展了其功能。