本文介紹了如何使用Spring Cloud Kafka Stream 3.1創(chuàng)建制片人的處理方法，對(duì)大家解決問(wèn)題具有一定的參考價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)吧！
問(wèn)題描述
我知道如何使用命令式編程方法定義生產(chǎn)者，但我找不到如何使用函數(shù)式編程方法定義生產(chǎn)者。
我讀了關(guān)于這個(gè)的Spring Cloud Stream Binder文檔，但只找到了如何定義消費(fèi)者，或者消費(fèi)者和生產(chǎn)者(例如，從主題中獲取信息，轉(zhuǎn)換數(shù)據(jù)并發(fā)送到另一個(gè)主題)。
所以，我不知道是否可以繼續(xù)使用像@Input、@Ouptut這樣的批注來(lái)定義單個(gè)處理器，在這一點(diǎn)上我非常困惑，因?yàn)閹?kù)表明這些批注已棄用，但我找不到定義向特定主題發(fā)送信息的簡(jiǎn)單生成器的示例或文檔。
謝謝！
文檔鏈接：
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將按時(shí)間間隔輪詢以生成輸出(如@Output頻道的@InboundChannelAdapter。
https://docs.spring.io/spring-cloud-stream/docs/3.1.0/reference/html/spring-cloud-stream.html#spring_cloud_function
或者，您可以使用StreamBridge將任意消息發(fā)送到輸出目標(biāo)。
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
這篇關(guān)于如何使用Spring Cloud Kafka Stream 3.1創(chuàng)建制片人的文章就介紹到這了，希望我們推薦的答案對(duì)大家有所幫助，
