配置改进

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

@@ -15,7 +15,7 @@ public class ConsumerApplication {
     }
 
     @Bean
-    public Consumer<Date> receive() {
+    public Consumer<Date> sink1() {
         return System.out::println;
     }
 }

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

@@ -3,10 +3,15 @@ spring:
     host: 192.168.133.128
     username: dev-user
     password: devpassword
+
   cloud:
     stream:
       bindings:
-        input:
-          destination: my-test-channel
+        sink1-in-0:
+          destination: test2
+    function:
+      definition: sink1
+
+
 server:
   port: 8081