使用goalng "github.com/Shopify/sarama"這個(gè)庫(kù)

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

看網(wǎng)上的文檔說(shuō)的是因?yàn)榉謪^(qū)不夠的原因，但是我現(xiàn)在設(shè)定了50個(gè)分區(qū)，只有兩個(gè)消費(fèi)者
代碼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實(shí)例地址], producerConfig)


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

這樣，投遞成功之后返回的分區(qū)id永遠(yuǎn)是0，我懷疑是不是因?yàn)槲曳謪^(qū)設(shè)置值沒(méi)有生效，

，但是因?yàn)槭堑谝淮斡胟afka,所以不確定，

于是使用下一個(gè)方式
代碼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實(shí)例地址], 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。

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

我現(xiàn)在懷疑是因?yàn)榉謪^(qū)配置沒(méi)有生效
請(qǐng)大神解答