go - 获取消费者的重复消息

Question

我已经使用此配置启动了 4 个消费者，有时多个消费者会收到相同的消息。

我已添加GroupID以防止重复

卡夫卡库：https ://github.com/segmentio/kafka-go

consumer := kafka.NewReader(kafka.ReaderConfig{
        Brokers:         kafkaBrokers,
        Topic:             "my-topic",
        StartOffset:     kafka.FirstOffset,
        MinBytes:        1,
        MaxBytes:        100e6,
        GroupID:          "my-group",
        MaxWait:         time.Hour * 24,
        ReadLagInterval: 1 * time.Second,
        Dialer:          dialer,
        QueueCapacity:   queueCapacity * 2,
    })

标签： goapache-kafka