Thank you. It looks like I had the 'topic' slightly wrong. I didn't realize it
was case-sensitive. I got past that error, but now I'm bumping up against
another error:
Traceback (most recent call last):
...
File "/usr/local/lib/python2.7/dist-packages/kafka/consumer/kafka.py", line
59, in __init__
self.set_topic_partitions(*topics)
File "/usr/local/lib/python2.7/dist-packages/kafka/consumer/kafka.py", line
242, in set_topic_partitions
self._get_commit_offsets()
File "/usr/local/lib/python2.7/dist-packages/kafka/consumer/kafka.py", line
618, in _get_commit_offsets
check_error(resp)
File "/usr/local/lib/python2.7/dist-packages/kafka/common.py", line 230, in
check_error
raise response
kafka.common.FailedPayloadsError
I've been told the producer is generating byte array data, not string data.
I'm unsure whether that is the cause or what to do about it.
Keith Wiley
Senior Software Engineer, Atigeo
[email protected]
________________________________________
From: JIEFU GONG <[email protected]>
Sent: Tuesday, July 28, 2015 01:31 PM
To: [email protected]
Subject: Re: KafkaConfigurationError: No topics or partitions configured
Can you confirm that there are indeed messages in the topic that you
published to?
bin/kafka-console-consumer.sh --zookeeper [details] --topic [topic]
--from-beginning
That should be the right command, and you can use that to first verify that
messages have indeed been published to the topic in question.
ᐧ
On Tue, Jul 28, 2015 at 11:33 AM, Keith Wiley <[email protected]>
wrote:
> 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/>
>
>
--
Jiefu Gong
University of California, Berkeley | Class of 2017
B.A Computer Science | College of Letters and Sciences
[email protected] <[email protected]> | (925) 400-3427
