python操作kafka

  2017-03-30  编程技术   2 分钟

安装

python

准备python环境,这次使用的是python 2.7,下载地址:https://www.python.org/

kafka moudle

下载python kafka moudle,下载地址:https://pypi.python.org/pypi/kafka-python

这次下载的是tar包,解压然后,python setup.py install即可安装

使用

KafkaConsumer

 from kafka import KafkaConsumer
 consumer = KafkaConsumer('my_favorite_topic')
 for msg in consumer:
     print (msg)

KafkaProducer

 from kafka import KafkaProducer
 producer = KafkaProducer(bootstrap_servers='localhost:9092')
 for _ in range(100):
     producer.send('foobar', b'some_message_bytes')

更多示例,参考:https://pypi.python.org/pypi/kafka-python

问题:

1.windows下执行python,遇到LookupError: unknown encoding: cp65001异常

编码格式错误,需要将编码修改为:简体中文
即:C:>chcp 936

— 转载本站文章请注明作者和出处全栈记 ,请勿用于任何商业用途

— 于 2017年03月30日 ,共写了 597 字;

— 本文共有 2 个标签:,

2条回应:“python操作kafka”

  1. shirley说道:

    文章和代码都写

发表评论

电子邮件地址不会被公开。 必填项已用*标注