kafka 消费者异常：Error reading field 'brokers': Error reading array of size 65535, 修订版本明细

源

采纳

编辑于

_阿呆

kafka 消费者异常：Error reading field 'brokers': Error reading array of size 65535,

kafka

已经确认server端和客户端版本都是0.11.0.1

消费者端报错如下：

org.apache.kafka.common.protocol.types.SchemaException: Error reading field 'brokers': Error reading array of size 65535, only 22 bytes available
    at org.apache.kafka.common.protocol.types.Schema.read(Schema.java:75)
    at org.apache.kafka.common.protocol.ApiKeys.parseResponse(ApiKeys.java:153)
    at org.apache.kafka.clients.NetworkClient.parseStructMaybeUpdateThrottleTimeMetrics(NetworkClient.java:560)
    at org.apache.kafka.clients.NetworkClient.handleCompletedReceives(NetworkClient.java:657)
    at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:442)
    at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:232)
    at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:208)
    at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:184)
    at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureCoordinatorReady(AbstractCoordinator.java:217)
    at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureCoordinatorReady(AbstractCoordinator.java:203)
    at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:286)
    at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1078)
    at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1043)
    at com.zte.ums.zenap.cometd.ReceiveKafkaMessage.run(ReceiveKafkaMessage.java:40)

求大神分析什么原因？

预览