カフカの読み取りエラーフィールドは、「CORRELATION_ID」：java.nio.BufferUnderflowException

Question

消費者にこのカフカ例外を取得：

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) 

ノークライアント・サーバ・バージョンの不一致。

Answer 1

クライアントが実際のカフカポートに接続していることを確認してください。 （のいずれか？）第ヘッダフィールド期待カフカメッセージの解析中にスタックトレースでResponseHeader.javaの呼び出しによって示されるように

この特定のエラーは、起こります。

これは、kafkaサーバーとは関係のないリスニングポートをターゲットにした場合に発生します。

ちょうど1分チェック！

それ以外の場合は、クライアントとサーバーのバージョンが一致していないかどうかを確認する必要があります。