我知道如何使用命令式编程方法定义生产者，但我找不到如何使用函数式编程方法定义生产者。
我阅读了springcloudstreambinder文档，但只找到了如何定义consumer或consumer&producer（例如，从主题中获取信息、转换数据并发送到另一个主题）。
所以，我不知道是否可以继续使用注解，比如 @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
1条答案
按热度按时间wkftcu5l1#
您可以定义
Supplier<?>
@Bean它将在一个时间间隔内进行轮询以生成输出（如@InboundChannelAdapter为了@Output频道。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