kafka-consumer-api - springframework.cloud.stream.messaging 包中的 Sink 是什么？

Question

我正在运行的应用程序将在 kafka 流中充当消费者。我通过 spring 的流配置了 kafka 消息传递。

如何确定它是否从正确的主题中消费？

springframework.cloud.stream.messaging 包中的 SINK 是什么？它扮演什么角色。如何配置它。什么是 Sink.INPUT？

Answer 1

我不确定我是否遵循您的问题，因为您没有提供任何示例。最初您说您已将应用程序配置为 spring-cloud-stream 应用程序，但随后您提出有关 Sink 的问题，这让我相信您实际上并没有按照您所说的去做，所以我很困惑。

我的建议是查看 spring-cloud-stream 示例 - https://github.com/spring-cloud/spring-cloud-stream-samples

此外，文档的这一部分解释了 Source、Processor 和 Sink 的概念 - https://cloud.spring.io/spring-cloud-static/spring-cloud-stream/2.2.1.RELEASE/spring-cloud- stream.html#_destination_bindings

最后，请注意，我们正朝着具有功能性方法的更简单的配置模型迈进。您可以从此博客获取更多信息，该博客还提供了获取更多详细信息的链接