Kafka Fehler beim Lesen Feld 'correlation_id': java.nio.BufferUnderflowException

Question

Erhalten dieses kafkas Ausnahme auf Verbraucher:

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) 

Kein Client-Server-Versionskonflikt.

Answer 1

Achten Sie darauf, dass Ihr Client eine Verbindung zu einem echten Kafka-Port herstellt!

Dieser spezifische Fehler tritt beim Parsen (eines?) Das erste Kopffeld der erwarteten kafka Nachricht, wie durch den Aufruf von ResponseHeader.java in Stack-trace gezeigt.

Das kann also passieren, wenn Sie auf einen Listening-Port abzielen, der nichts mit dem Kafka-Server zu tun hat.

nur 1 Minute prüfen!

Andernfalls sollten Sie prüfen, ob eine Client-Server-Version nicht übereinstimmt.