| 123456789101112131415161718192021 |
- spring:
- application:
- name: pay
- cloud:
- function:
- definition: orderCancelConsumer;userRegisterConsumer
- stream:
- rocketmq:
- binder:
- name-server: 127.0.0.1:9876
- bindings:
- orderCancelConsumer-in-0: # 消费者输入通道
- destination: order-timeout-topic
- content-type: application/json
- group: pay-service-group # 消费者组
- userRegisterConsumer-in-0:
- destination: user-register-topic # 与生产者Topic名称一致
- content-type: application/json
- group: pay-service-group # 消费者组,用于集群消费和负载均衡
- server:
- port: 18075
|