Hi,
I'm using High Level Consumer with kafka 0.7.2. The consumer is able to
consume messages from kafka for the first time but when I restart the
consumer process, I'm getting the following error:
2013-06-24 09:48:25 FetchRunnable-0 [ERROR] FetcherRunnable:89 - error in
FetcherRunnable
kafka.network.InvalidRequestException: -2147400679 is not a valid request
size.
at
kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:60)
at kafka.network.Receive$class.readCompletely(Transmission.scala:55)
at
kafka.network.BoundedByteBufferReceive.readCompletely(BoundedByteBufferReceive.scala:29)
at kafka.consumer.SimpleConsumer.getResponse(SimpleConsumer.scala:177)
at kafka.consumer.SimpleConsumer.liftedTree2$1(SimpleConsumer.scala:117)
at kafka.consumer.SimpleConsumer.multifetch(SimpleConsumer.scala:115)
at kafka.consumer.FetcherRunnable.run(FetcherRunnable.scala:60)
I'm not sure how is it getting -2147400679 as the request size. Any ideas
or pointers what may be wrong here?
Thanks,
Anand