Я пытаюсь использовать 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)