Nats 无法为没有交付组的消费者创建队列订阅

Question

我正在尝试在一个队列中创建多个订阅者，因此每条消息只能由其中一个读取。当我第二次尝试QueueSubscribe时出现错误：cannot create a queue subscription for a consumer without a deliver group.

我尝试在一个应用程序中创建两个订阅者并尝试运行两个实例，这是同样的错误。

以下是订阅者：

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属性，但没有帮助。

Answer 1

由于 nats 服务器（2.3.6）的版本而出现问题，更新到 2.7.2 后一切正常。库与旧版本不兼容。