1

我正在尝试将pykafkardkafka一起使用来使用消息,但是在尝试初始化使用者时出现以下错误。

配置属性“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)
4

0 回答 0