fix:rocketmq funtion.definition config

zhangqian9158 · May 13, 2024 · 99fdcca · 99fdcca
1 parent d718b9a
commit 99fdcca
Show file tree

Hide file tree

Showing 7 changed files with 14 additions and 14 deletions.
diff --git a/...broadcast-example/rocketmq-broadcast-consumer1-example/src/main/resources/application.yml b/...broadcast-example/rocketmq-broadcast-consumer1-example/src/main/resources/application.yml
@@ -4,9 +4,9 @@ spring:
   application:
     name: rocketmq-broadcast-consumer1-example
   cloud:
+    function:
+      definition: consumer;
     stream:
-      function:
-        definition: consumer;
       rocketmq:
         binder:
           name-server: localhost:9876

diff --git a/...broadcast-example/rocketmq-broadcast-consumer2-example/src/main/resources/application.yml b/...broadcast-example/rocketmq-broadcast-consumer2-example/src/main/resources/application.yml
@@ -4,9 +4,9 @@ spring:
   application:
     name: rocketmq-broadcast-consumer2-example
   cloud:
+    function:
+      definition: consumer;
     stream:
-      function:
-        definition: consumer;
       rocketmq:
         binder:
           name-server: localhost:9876

diff --git a/...amples/rocketmq-example/rocketmq-comprehensive-example/src/main/resources/application.yml b/...amples/rocketmq-example/rocketmq-comprehensive-example/src/main/resources/application.yml
@@ -4,9 +4,9 @@ spring:
   application:
     name: rocketmq-comprehensive-example
   cloud:
+    function:
+      definition: producer;consumer;processor
     stream:
-      function:
-        definition: producer;consumer;processor
       rocketmq:
         binder:
           name-server: 127.0.0.1:9876

diff --git a/...amples/rocketmq-example/rocketmq-delay-consume-example/src/main/resources/application.yml b/...amples/rocketmq-example/rocketmq-delay-consume-example/src/main/resources/application.yml
@@ -4,9 +4,9 @@ spring:
   application:
     name: rocketmq-delay-consume-example
   cloud:
+    function:
+      definition: consumer;
     stream:
-      function:
-        definition: consumer;
       rocketmq:
         binder:
           name-server: localhost:9876

diff --git a/...ples/rocketmq-example/rocketmq-orderly-consume-example/src/main/resources/application.yml b/...ples/rocketmq-example/rocketmq-orderly-consume-example/src/main/resources/application.yml
@@ -4,9 +4,9 @@ spring:
   application:
     name: rocketmq-orderly-consume-example
   cloud:
+    function:
+      definition: consumer;
     stream:
-      function:
-        definition: consumer;
       rocketmq:
         binder:
           name-server: localhost:9876

diff --git a/...examples/rocketmq-example/rocketmq-sql-consume-example/src/main/resources/application.yml b/...examples/rocketmq-example/rocketmq-sql-consume-example/src/main/resources/application.yml
@@ -4,9 +4,9 @@ spring:
   application:
     name: rocketmq-sql-consume-example
   cloud:
+    function:
+      definition: consumer;
     stream:
-      function:
-        definition: consumer;
       rocketmq:
         binder:
           name-server: localhost:9876

diff --git a/...-alibaba-examples/rocketmq-example/rocketmq-tx-example/src/main/resources/application.yml b/...-alibaba-examples/rocketmq-example/rocketmq-tx-example/src/main/resources/application.yml
@@ -4,9 +4,9 @@ spring:
   application:
     name: rocketmq-tx-example
   cloud:
+    function:
+      definition: consumer;
     stream:
-      function:
-        definition: consumer;
       rocketmq:
         binder:
           name-server: localhost:9876