I'm trying to get a basic consumer off the ground. I can create the consumer
but I can't do anything at the message level:
consumer = KafkaConsumer(topic,
group_id=group_id,
bootstrap_servers=[ip + ":" + port])
for m in consumer:
print "x"
Note that I'm not even trying to use the message, I'm just trying loop over the
consumer. I'm getting an exception there somehow:
Exception: No topics or partitions configured
Traceback (most recent call last):
File "<timed exec>", line 3, in <module>
File "/usr/local/lib/python2.7/dist-packages/kafka/consumer/kafka.py", line
290, in next
return six.next(self._get_message_iterator())
File "/usr/local/lib/python2.7/dist-packages/kafka/consumer/kafka.py", line
324, in fetch_messages
raise KafkaConfigurationError('No topics or partitions configured')
KafkaConfigurationError: No topics or partitions configured
Any ideas? I've been assured (although perhaps incorrectly) that the producer
is configured, up and running. Thanks.
Keith Wiley
Senior Software Engineer, Atigeo
[email protected]
[atigeo]<http://atigeo.com/>
[twitter]<https://twitter.com/atigeo> [LinkedIn]
<https://www.linkedin.com/company/atigeo> [YouTube]
<https://www.youtube.com/user/AtigeoXpatterns/> [blog]
<http://xpatterns.com/blog/>
