kafka多個消費者只有一個消費

使用goalng "github.com/Shopify/sarama"這個庫

我現(xiàn)在有兩個消費者，兩個topic,kafka分區(qū)設(shè)定是50個，但是在實際運行過程中只有一個消費者在消費，關(guān)閉當(dāng)前能消費的消費者，另外一個也可以消費，但是同時運行是就不行

看網(wǎng)上的文檔說的是因為分區(qū)不夠的原因，但是我現(xiàn)在設(shè)定了50個分區(qū)，只有兩個消費者
代碼1

    producerConfig := sarama.NewConfig()
    producerConfig.Producer.Partitioner = sarama.NewHashPartitioner
    producerConfig.Producer.Return.Successes = true
    producerConfig.Producer.Timeout = 5 * time.Second
    producer, err = sarama.NewSyncProducer([broker實例地址], producerConfig)


    kafka_msg := &sarama.ProducerMessage{
        Topic:topic,
        Key:sarama.StringEncoder(key),
        Value: sarama.StringEncoder(value),
    }
    partition, offset, err := producer.SendMessage(kafka_msg)

這樣，投遞成功之后返回的分區(qū)id永遠是0，我懷疑是不是因為我分區(qū)設(shè)置值沒有生效，

，但是因為是第一次用kafka,所以不確定，

于是使用下一個方式
代碼2

    producerConfig := sarama.NewConfig()
    // producerConfig.Producer.Partitioner = sarama.NewHashPartitioner
    producerConfig.Producer.Return.Successes = true
    producerConfig.Producer.Timeout = 5 * time.Second
    producer, err = sarama.NewSyncProducer([broker實例地址], producerConfig)


    kafka_msg := &sarama.ProducerMessage{
        Topic:topic,
        Key:sarama.StringEncoder(key),
        Value: sarama.StringEncoder(value),
        Partition: 7 ,
    }
    partition, offset, err := producer.SendMessage(kafka_msg)

這樣設(shè)置后投遞成功分區(qū)返回也是0。

我想確認的是，在分區(qū)設(shè)置生效的前提先，如果我用代碼2來寫，最終投遞到的分區(qū)是不是7 ？

我現(xiàn)在懷疑是因為分區(qū)配置沒有生效
請大神解答