kafka.network.InvalidRequestException

There are no available Samebug tips for this exception. Do you have an idea how to solve this issue? A short tip would help users who saw this issue last week.

  • GitHub comment 92#231059731
    via GitHub by marshauf
    ,
  • librdkafka sends a Null Metadata string (size -1) in its OffsetCommitRequests when there is no metadata, this unfortunately leads to an exception on the broker that expects a non-null string. {noformat} [2016-03-11 11:11:57,623] ERROR Closing socket for 10.191.0.33:9092-10.191.0.33:56503 because of error (kafka.network.Processor) kafka.network.InvalidRequestException: Error getting request for apiKey: 8 and apiVersion: 1 at kafka.network.RequestChannel$Request.liftedTree2$1(RequestChannel.scala:91) at kafka.network.RequestChannel$Request.<init>(RequestChannel.scala:88) at kafka.network.Processor$$anonfun$run$11.apply(SocketServer.scala:426) at kafka.network.Processor$$anonfun$run$11.apply(SocketServer.scala:421) at scala.collection.Iterator$class.foreach(Iterator.scala:727) at scala.collection.AbstractIterator.foreach(Iterator.scala:1157) at scala.collection.IterableLike$class.foreach(IterableLike.scala:72) at scala.collection.AbstractIterable.foreach(Iterable.scala:54) at kafka.network.Processor.run(SocketServer.scala:421) at java.lang.Thread.run(Thread.java:745) Caused by: org.apache.kafka.common.protocol.types.SchemaException: Error reading field 'topics': Error reading field 'partitions': Error reading field 'metadata': java.lang.NegativeArraySizeException at org.apache.kafka.common.protocol.types.Schema.read(Schema.java:73) at org.apache.kafka.common.requests.OffsetCommitRequest.parse(OffsetCommitRequest.java:260) at org.apache.kafka.common.requests.AbstractRequest.getRequest(AbstractRequest.java:50) at kafka.network.RequestChannel$Request.liftedTree2$1(RequestChannel.scala:88) ... 9 more {noformat}
    via by Magnus Edenhill,
  • Full Rejoin attempt failed.
    via GitHub by raviten
    ,
  • SchemaRegistryMain read error
    via GitHub by gitmahmud
    ,
    • kafka.network.InvalidRequestException: Error getting request for apiKey: 8 and apiVersion: 2 at kafka.network.RequestChannel$Request.liftedTree2$1(RequestChannel.scala:95) at kafka.network.RequestChannel$Request.<init>(RequestChannel.scala:87) at kafka.network.Processor$$anonfun$processCompletedReceives$1.apply(SocketServer.scala:488) at kafka.network.Processor$$anonfun$processCompletedReceives$1.apply(SocketServer.scala:483) at scala.collection.Iterator$class.foreach(Iterator.scala:893) at scala.collection.AbstractIterator.foreach(Iterator.scala:1336) at scala.collection.IterableLike$class.foreach(IterableLike.scala:72) at scala.collection.AbstractIterable.foreach(Iterable.scala:54) at kafka.network.Processor.processCompletedReceives(SocketServer.scala:483) at kafka.network.Processor.run(SocketServer.scala:413) at java.lang.Thread.run(Thread.java:745) Caused by: org.apache.kafka.common.protocol.types.SchemaException: Error reading field 'member_id': String length -1 cannot be negative at org.apache.kafka.common.protocol.types.Schema.read(Schema.java:73) at org.apache.kafka.common.requests.OffsetCommitRequest.parse(OffsetCommitRequest.java:260) at org.apache.kafka.common.requests.AbstractRequest.getRequest(AbstractRequest.java:50) at kafka.network.RequestChannel$Request.liftedTree2$1(RequestChannel.scala:92) ... 10 more

    Users with the same issue

    johnxflyjohnxfly
    57 times, last one,
    Unknown visitor
    Unknown visitor1 times, last one,
    Unknown visitor
    Unknown visitor1 times, last one,
    Unknown visitor
    Unknown visitor1 times, last one,
    Unknown visitor
    Unknown visitor1 times, last one,
    15 more bugmates