Reply
Highlighted
Explorer
Posts: 6
Registered: ‎09-11-2015

Can't fetch data from Kafka 2.0.1 using Kafka client 0.8

There should be backward capability, but looks like it broken

On client side I've got an error

java.io.EOFException: Received -1 when reading from channel, socket has
likely been closed.
        at kafka.utils.Utils$.read(Utils.scala:381)
        at
kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:54)
        at kafka.network.Receive$class.readCompletely(Transmission.scala:56)

On broker side

kafka.network.InvalidRequestException: Error getting request for apiKey: 2 and apiVersion: 1
        at kafka.network.RequestChannel$Request.liftedTree2$1(RequestChannel.scala:93)
        at kafka.network.RequestChannel$Request.<init>(RequestChannel.scala:90)
        at kafka.network.Processor$$anonfun$run$11.apply(SocketServer.scala:426)
        at kafka.network.Processor$$anonfun$run$11.apply(SocketServer.scala:421)
Announcements
New solutions