kafka client版本兼容问题修订版本明细

源

采纳

编辑于 3年前

起风了

kafka client版本兼容问题

kafka

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)

预览