Pykafka消费者客户需要将参数'use_greenlets'设置为true吗？

问题描述

我现在写一个脚本。我对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 (将#修改为@）

gevent pykafka python