问题描述
我现在写一个脚本。 我对kafka消费者中的参数“ use_greenlets”感到困惑,我认为在Consumer中没有区别。 那么,我应该在使用者模块中将'use_greenlets'设置为true吗? 谢谢。
#!/usr/bin/env python
# -*-coding:utf-8-*-
"""
c1
"""
import os.path as op
from pykafka import KafkaClient
#
hp = "127.0.0.1:9092"
client = KafkaClient(hosts=hp,use_greenlets=True)
topic = client.topics['test']
consumer = topic.get_balanced_consumer(
consumer_group="mygroup",reset_offset_on_start=False,auto_offset_reset=-1,)
fn = op.basename(__file__)
for num,message in enumerate(consumer):
if message is not None:
print(fn,message.offset,message.value.decode('utf-8'))
consumer.commit_offsets()
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)