小编Dea*_*tle的帖子

我尝试过shopify/sarama库来使用kafka消息。Consumer接口和接口我都用过ConsumerGroup。我可以使用ConsumePartition()中的方法从特定分区消费Consumer。但是当我使用ConsumerGroup接口时，我似乎没有能力从特定分区消费。

有没有办法让我将某些分区分配给消费者组内的特定消费者？或者这是我无法干涉的事情？