我正在尝试将pykafka与rdkafka一起使用来使用消息,但是在尝试初始化使用者时出现以下错误。
配置属性“queued.max.messages.kbytes”值 102400000 超出允许范围 1..2097151
以下是我的代码。有人可以帮我解决这个错误吗?
from pykafka import KafkaClient
client = KafkaClient(broker)
topic = client.topics['test_topic']
consumer = topic.get_simple_consumer(use_rdkafka=True)