從使用Python

Question

我有3個分區的話題，我想用從每一特定分區閱讀下面的代碼

from kafka import KafkaConsumer, TopicPartition 

brokers = 'localhost:9092' 
topic = 'b3' 

m = KafkaConsumer(topic, bootstrap_servers=['localhost:9092']) 
par = TopicPartition(topic=topic, partition=1) 
m.assign(par) 

但我得到這個錯誤具體卡夫卡主題閱讀：

raise IllegalStateError(self._SUBSCRIPTION_EXCEPTION_MESSAGE) 
kafka.errors.IllegalStateError: IllegalStateError: You must choose only one way to configure your consumer: (1) subscribe to specific topics by name, (2) subscribe to topics matching a regex pattern, (3) assign itself specific topic-partitions. 

有人可以幫助我嗎？

Answer 1

你可以刪除KafkaConsumer（專題參數），然後再試一次？

例如：

# manually assign the partition list for the consumer 
from kafka import TopicPartition, KafkaConsumer 
consumer = KafkaConsumer(bootstrap_servers='localhost:1234') 
consumer.assign([TopicPartition('foobar', 2)]) 
msg = next(consumer) 

裁判：http://kafka-python.readthedocs.io/en/master/