多主题配置

consumer/consumer-server/src/main/java/top/fjy8018/consumer/ConsumerApplication.java

@@ -18,4 +18,9 @@ public class ConsumerApplication {
     public Consumer<Date> sink1() {
         return System.out::println;
     }
+
+    @Bean
+    public Consumer<String> sink2() {
+        return System.out::println;
+    }
 }

consumer/consumer-server/src/main/resources/application.yml

@@ -9,8 +9,10 @@ spring:
       bindings:
         sink1-in-0:
           destination: test2
+        sink2-in-0:
+          destination: test3
     function:
-      definition: sink1
+      definition: sink1;sink2
 
 
 server: