我正在嘗試在一個(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屬性,但沒(méi)有幫助。
Nats 無(wú)法為沒(méi)有交付組的消費(fèi)者創(chuàng)建隊(duì)列訂閱
www說(shuō)
2022-11-08 15:50:20