我正在嘗試在一個(gè)隊(duì)列中創(chuàng)建多個(gè)訂閱者,因此每條消息只能由其中一個(gè)讀取。當(dāng)我第二次嘗試QueueSubscribe時(shí)出現(xiàn)錯(cuò)誤:cannot create a queue subscription for a consumer without a deliver group.我嘗試在一個(gè)應(yīng)用程序中創(chuàng)建兩個(gè)訂閱者并嘗試運(yùn)行兩個(gè)實(shí)例,這是同樣的錯(cuò)誤。以下是訂閱者:s1, err = js.QueueSubscribe( "KEYS.group", "queue", func(m *nats.Msg) { fmt.Printf("1: %s\n", m.Data) }, )s2, err = js.QueueSubscribe( "KEYS.group", "queue", func(m *nats.Msg) { fmt.Printf("2: %s\n", m.Data) }, )和出版商:_, err := js.AddStream(&nats.StreamConfig{ Name: "KEYS", Subjects: []string{"KEYS.group"}, Retention: nats.WorkQueuePolicy, // tried with default policy if it may be relevant })for i := 0; i < 20; i++ { msg := fmt.Sprintf(`{"key": "%d"}`, i) if _, err := js.Publish("KEYS.group", []byte(msg)); err != nil { print(err) } }我也嘗試添加Durable屬性,但沒有幫助。
1 回答
寶慕林4294392
TA貢獻(xiàn)2021條經(jīng)驗(yàn) 獲得超8個(gè)贊
由于 nats 服務(wù)器(2.3.6)的版本而出現(xiàn)問題,更新到 2.7.2 后一切正常。庫與舊版本不兼容。
- 1 回答
- 0 關(guān)注
- 156 瀏覽
添加回答
舉報(bào)
0/150
提交
取消
