文章/答案/技术大牛

发布

社区首页 >问答首页 >如何使用Spring Cloud Kafka Stream 3.1创建生产者

问如何使用Spring Cloud Kafka Stream 3.1创建生产者
EN

Stack Overflow用户

提问于 2021-01-22 05:25:34

回答 1查看 893关注 0票数 2

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

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

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

谢谢!

文档链接：https://docs.spring.io/spring-cloud-stream-binder-kafka/docs/3.0.10.RELEASE/reference/html/spring-cloud-stream-binder-kafka.html#_kafka_streams_binder

java

spring

apache-kafka

spring-cloud-stream

回答 1

Stack Overflow用户

发布于 2021-01-22 05:58:11

您可以定义一个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

票数 3

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/65835964

复制

相似问题

问如何使用Spring Cloud Kafka Stream 3.1创建生产者
EN

回答 1

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问如何使用Spring Cloud Kafka Stream 3.1创建生产者EN

回答 1

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问如何使用Spring Cloud Kafka Stream 3.1创建生产者
EN