本文介紹了如何使用Spring Cloud Kafka Stream 3.1創建制片人的處理方法，對大家解決問題具有一定的參考價值，需要的朋友們下面隨著小編來一起學習吧！
問題描述
我知道如何使用命令式編程方法定義生產者，但我找不到如何使用函數式編程方法定義生產者。
我讀了關于這個的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
推薦答案
您可以定義Supplier<?>@Bean，該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
這篇關于如何使用Spring Cloud Kafka Stream 3.1創建制片人的文章就介紹到這了，希望我們推薦的答案對大家有所幫助，
