卡夫卡普顿大教堂kafka.errors.ConsumerFetchSizeTooSm

Question

我正在用python2.7编写一个简单的代码，它使用来自apachekafka主题的消息传递。代码如下：

from kafka import SimpleConsumer,KafkaClient
group = "my_group_test"
client = KafkaClient('localhost:9092')
cons = SimpleConsumer(client, group, "my_topic")
messages = cons.get_messages(count=1000,block=False)

但提出了这个例外：

^{pr2}$

如何修改此参数（ConsumerFetchSize）以使此代码正常工作？在

Answer 1

我找到了解决办法， 在SimpleConsumer中使用参数max_buffer_size。在

工作代码是：

#the size is adherent with my need but is totally arbitrary
cons = SimpleConsumer(client, group, "my_topic",max_buffer_size=9932768)