kafka消费者创建失败,Packet ...is out of range

qq_dafgs3r6 Kafka 基础实战 :消费者... 最后由 qq_dafgs3r6 于2017年09月04日回复

  • 2 回答
  • 1.1k 浏览

创建消费者失败。先是报IOException: packet len1213486160 is out of range

然后报异常ZKTimeoutExcetion : unable to connect to zookeeper server whitin timeout 

最终出错是在

 consumer =kafka.consumer.Consumer   
                    .createJavaConsumerConnector(createConsumerConfig()); 
  • 极客学院_吕布 2017年09月04日 回答 #1楼
  • 可以通过参数jute.maxbuffer来设置一个更大的参数即可。用于配置单个数据节点上可以存储的最大数据量大小。需要注意的是在变更该参数的时候,需要在zookeeper集群中的所有机器以及所有的客户端上均设置才能生效。

  • 0 评论