kafka client版本兼容问题

起风了 发表于: 2021-12-06   最后更新时间: 2021-12-06 15:56:17   1,484 游览

0.10.2.0的client消费2.4.0版本的Kafka集群出现以下错误，之前该Client消费2.6.2的Kafka也没有出现问题

应该是client版本太低了，可以不升级client解决吗？不是低版本的client兼容高版本的Kafka集群吗？

java.lang.IllegalStateException: Unexpected error code 35 while fetching data
        at org.apache.kafka.clients.consumer.internals.Fetcher.parseFetchedData(Fetcher.java:725)
        at org.apache.kafka.clients.consumer.internals.Fetcher.fetchedRecords(Fetcher.java:424)
        at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1045)
        at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:979)
        at poll(Consumer.java:30)
kafka
发表于 2021-12-06
起风了
添加评论

那你可能要改源码了，版本兼容问题并不是会覆盖全部版本的。

但是，我看你这个报错是解析数据的格式报错了，你可以尝试都使用旧版本的客户端发一个新主题，看看是否会报错。

回复
回答于 3年前
半兽人
你的答案

查看kafka相关的其他问题或提一个您自己的问题。
提问

找不到想要的答案？提一个您自己的问题。