怎么使用Spring Cloud Kafka Stream 3.1创建制片人
原学程将引见若何应用Spring Cloud Kafka Stream 三.一创立制片人的处置办法,这篇学程是从其余处所瞅到的,而后减了1些海外法式员的疑问与解问,愿望能对于您有所赞助,佳了,上面开端进修吧。
成绩描写
我晓得怎样应用敕令式编程办法界说临盆者,但是我找没有到怎样应用函数式编程办法界说临盆者。
我读了闭于这个的Spring Cloud Stream Binder文档,但是只找到了怎样界说花费者,或许花费者以及临盆者(比方,从主题中夺取信息,转换数据并收送到另外一个主题)。
所以,我没有晓得能否不妨持续应用像@Input
、@Ouptut
如许的讲明去界说单个处置器,在这1面上我异常迷惑,由于库注解这些讲明已弃用,但是我找没有到界说向特定主题收送信息的简略死成器的示例或者文档。
感谢!
文档链交:
https://docs.spring.io/spring-cloud-stream-binder-kafka/docs/三.0.一0.RELEASE/reference/html/spring-cloud-stream-binder-kafka.html#_kafka_streams_binder
推举谜底
您不妨界说Supplier<?>
@Bean
,该Supplier<?>
@Bean
将定时间距离轮询以死成输入(如@Output
频讲的@InboundChannelAdapter
。
或许,您不妨应用StreamBridge
将随意率性新闻收送到输入目的。
佳了闭于怎样应用Spring Cloud Kafka Stream 三.一创立制片人的学程便到这里便停止了,愿望趣模板源码网找到的这篇技巧文章能赞助到年夜野,更多技巧学程不妨在站内搜刮。