在消费者上获取此 kafka 异常:
org.apache.kafka.common.protocol.types.SchemaException: Error reading field 'correlation_id': java.nio.BufferUnderflowException
at org.apache.kafka.common.protocol.types.Schema.read(Schema.java:71)
at org.apache.kafka.common.requests.ResponseHeader.parse(ResponseHeader.java:53)
at org.apache.kafka.clients.NetworkClient.handleCompletedReceives(NetworkClient.java:435)
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:265)
at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.clientPoll(ConsumerNetworkClient.java:320)
at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:213)
at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:193)
at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.awaitMetadataUpdate(ConsumerNetworkClient.java:134)
at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureCoordinatorKnown(AbstractCoordinator.java:184)
at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:886)
at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:853)
没有客户端-服务器版本不匹配。
最佳答案
Be sure your client connect to a real Kafka port !
在解析预期 kafka 消息的第一个 header 字段(其中一个？)时发生此特定错误，如调用堆栈中的 ResponseHeader.java 所示 -跟踪。
因此，如果您的目标监听端口与 kafka 服务器无关，则可能会发生这种情况。
just a 1 minute check !
否则，您应该检查客户端-服务器版本是否不匹配。
关于java - Kafka 读取字段时出错 'correlation_id' : java. nio.BufferUnderflowException，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/44417033/