当前位置： 移动技术网 > IT编程>脚本编程>Python > Python 基于pykafka简单实现KAFKA消费者

Python 基于pykafka简单实现KAFKA消费者

2019年03月18日  | 移动技术网IT编程  | 我要评论

男子草丛发现异物 捅破后被吓尿,强上黑老大全文阅读,yahuyouxiang

基于pykafka简单实现kafka消费者

  by: 授客 qq：1033553122

 

 

 

 

1．测试环境

python 3.4

 

zookeeper-3.4.13.tar.gz

下载地址1：

 

下载地址2：

https://pan.baidu.com/s/1dnbghvyse9pvrzxjvmezyq

 

kafka_2.12-2.1.0.tgz

下载地址1：

下载地址2：

https://pan.baidu.com/s/1vnhkjgy4iq73j5rlbel0jw

 

pykafka-2.8.0.tar.gz

下载地址1：

 

 

2．问题描述

使用python-kafka类库实现kafka消费者时，发现程序有时候会自动停止消费，对一些参数进行配置后无果，换成pykafka类库实现，搞定

 

 

3．代码简单实现

 

 

#-*- encoding:utf-8 -*-

 

__author__ = 'shouke'

 

from pykafka import kafkaclient

 

 

client = kafkaclient(hosts="127.0.0.1:9092")

 

# 获取主题

print(client.topics)

 

topic = client.topics['my_topic1']

 

# 获取消费者

consumer  = topic.get_balanced_consumer('my_group1', auto_commit_enable=true, auto_commit_interval_ms=3000)

for message in consumer:

    if message is not none:

        print(message.offset, message.value)

 

 

 

参考链接:

您可能感兴趣的文章:

如对本文有疑问，请在下面进行留言讨论，广大热心网友会与你互动！！ 点击进行留言回复

相关文章:

验证码：
最近更新的文章
大家感兴趣的文章
移动技术网