Spring Cloud Stream使用者目的地配置

2024-01-10 16:00 更新

如果打開(kāi)自動(dòng)資源創(chuàng)建功能,并且對(duì)于用戶而言不存在訂閱和/或主題,則將創(chuàng)建訂閱和潛在的主題。主題名稱將與目標(biāo)名稱相同,訂閱名稱將是目標(biāo)名稱,后跟使用者組名稱。

不管auto-create-resources設(shè)置如何,如果未指定使用者組,都會(huì)創(chuàng)建一個(gè)名稱為anonymous.<destinationName>.<randomUUID>的匿名用戶組。然后,當(dāng)活頁(yè)夾關(guān)閉時(shí),將自動(dòng)清除為匿名使用者組創(chuàng)建的所有發(fā)布/訂閱。

例如,對(duì)于以下配置,將創(chuàng)建名為myEvents的主題和名為myEvents.counsumerGroup1的訂閱。如果未指定使用者組,則將創(chuàng)建一個(gè)名為anonymous.myEvents.a6d83782-c5a3-4861-ac38-e6e2af15a7be的訂閱,并隨后對(duì)其進(jìn)行清理。

如果您要為消費(fèi)者手動(dòng)創(chuàng)建發(fā)布/訂閱,請(qǐng)確保它們遵循<destinationName>.<consumerGroup>的命名約定。

application.properties。 

spring.cloud.stream.bindings.events.destination=myEvents
spring.cloud.stream.gcp.pubsub.bindings.events.consumer.auto-create-resources=true

# specify consumer group, and avoid anonymous consumer group generation
spring.cloud.stream.bindings.events.group=consumerGroup1


以上內(nèi)容是否對(duì)您有幫助:
在線筆記
App下載
App下載

掃描二維碼

下載編程獅App

公眾號(hào)
微信公眾號(hào)

編程獅公眾號(hào)