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)
那你可能要改源码了,版本兼容问题并不是会覆盖全部版本的。
但是,我看你这个报错是解析数据的格式报错了,你可以尝试都使用旧版本的客户端发一个新主题,看看是否会报错。
你的答案