search

Yelp / pyleus

Pyleus is a Python framework for developing and launching Storm topologies.
Apache License 2.0
404 stars 113 forks source link

Question for using kafka-client #138

Open linxinsnow opened 8 years ago

linxinsnow commented 8 years ago

【kafka-python-0.9.4】

from kafka import KafkaConsumer

File "/private/var/folders/jb/smm0c4k544j2fs_vk3d_7ykc0000gn/T/tmpC5rDzV/resources/logging_example/line_spout.py", line 4, in from kafka import KafkaConsumer ImportError: No module named kafka

It is ok when I load the kafka module in python console.

Python 2.7.9 (default, Dec 10 2014, 23:46:04) [GCC 4.2.1 Compatible Apple LLVM 6.0 (clang-600.0.56)] on darwin Type "help", "copyright", "credits" or "license" for more information.

import kafka

poros commented 8 years ago

Could you be a bit more precise? Are you running your topology locally or on a Storm cluster? Are you running the vanilla logging example?