You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by 宋扬 <42...@qq.com> on 2019/05/26 02:58:04 UTC
About Error in Kafka 0.9

Hi Dev,
 
Sorry to bother you, we use Kafka as MQ tools, the version is 0.9.0.1, now there have some error:
 
1.     [kafka-producer-network-thread | producer-1]  ERROR o.a.k.c.producer.internals.Sender     -Uncaught error in kafka producer I/O thread: 
 
java.lang.IllegalStateException: Correlation id for response (3314259) does not match request (3314258)
 
     at org.apache.kafka.clients.NetworkClient.correlate(NetworkClient.java:477)
 
     at org.apache.kafka.clients.NetworkClient.handleCompletedReceives(NetworkClient.java:440)
 
     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:265)
 
     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:216)
 
     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:128)
 
     at java.lang.Thread.run(Thread.java:745)
 
2.     [pool-3-thread-3] ERROR c.m.s.f.mq.consumer.SmartConsumer       -error init consumer or poll message form kafka!
 
org.apache.kafka.common.protocol.types.SchemaException: Error reading field 'responses': java.nio.BufferUnderflowException
 
     at org.apache.kafka.common.protocol.types.Schema.read(Schema.java:71)
 
     at org.apache.kafka.clients.NetworkClient.handleCompletedReceives(NetworkClient.java:439)
 
     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.KafkaConsumer.pollOnce(KafkaConsumer.java:908)
 
     at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:853)
 
   …….
 
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
 
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
 
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
 
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
 
     at java.lang.Thread.run(Thread.java:745)
 
3.     org.apache.kafka.common.protocol.types.SchemaException: Error reading field 'brokers': Error reading field 'host': Error reading string of length 12592, only 2413 bytes available
 
at org.apache.kafka.common.protocol.types.Schema.read(Schema.java:73)
 
     at org.apache.kafka.clients.NetworkClient.parseResponse(NetworkClient.java:380)
 
     at org.apache.kafka.clients.NetworkClient.handleCompletedReceives(NetworkClient.java:449)
 
     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:269)
 
     at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.clientPoll(ConsumerNetworkClient.java:360)
 
     at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:224)
 
     at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:192)
 
     at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:163)
 
     at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureCoordinatorReady(AbstractCoordinator.java:179)
 
     at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:973)
 
     at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:937)
 
   ……
 
     at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
 
     at java.util.concurrent.FutureTask.run(FutureTask.java:266)
 
     at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
 
     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
 
     at java.lang.Thread.run(Thread.java:745)


Please help me thanks.


Michael song