学新通技术网

Spring Cloud怎么使用 Kafka Stream 3.1 创建生产者

it1352 38 1
Spring Cloud怎么使用 Kafka Stream 3.1 创建生产者

前言

Spring Cloud怎么使用 Kafka Stream 3.1 创建生产者

问题

我知道如何使用命令式编程方法定义生产者,但我找不到如何使用函数式编程方法定义生产者。

我读了关于这个的Spring Cloud Stream Binder文档,但只找到了如何定义消费者,或者消费者和生产者(例如,从主题中获取信息,转换数据并发送到另一个主题)。

所以,我不知道是否可以继续使用像@Input@Ouptut这样的批注来定义单个处理器,在这一点上我非常困惑,因为库表明这些批注已弃用,但我找不到定义向特定主题发送信息的简单生成器的示例或文档。

答案

您可以定义

Supplier<?>@Bean

将按时间间隔轮询以生成输出(如@Output频道的@InboundChannelAdapter

https://docs.spring.io/spring-cloud-stream/docs/3.1.0/reference/html/spring-cloud-stream.html#spring_cloud_function

您也可以使用StreamBridge来将任何消息发送到目标输出。

https://docs.spring.io/spring-cloud-stream/docs/3.1.0/reference/html/spring-cloud-stream.html#_sending_arbitrary_data_to_an_output_e_g_foreign_event_driven_sources

本文出至:学新通技术网

标签:

上一篇:

下一篇: