David Arthur created KAFKA-523: ---------------------------------- Summary: OffsetRequest handler does not handle errors Key: KAFKA-523 URL: https://issues.apache.org/jira/browse/KAFKA-523 Project: Kafka Issue Type: Bug Components: core Affects Versions: 0.7.1 Reporter: David Arthur Priority: Minor
There is not error handling in the KafkaRequestHandlers#handleOffsetRequest, as a result invalid requests get no data back since they raise an Exception in the server. E.g., I make an OffsetRequest for an invalid partition I get no response on the client side, and I see the following exception in Kafka server logs {code} kafka.common.InvalidPartitionException: wrong partition 10 at kafka.log.LogManager.getOrCreateLog(LogManager.scala:169) at kafka.server.KafkaRequestHandlers.handleOffsetRequest(KafkaRequestHandlers.scala:130) at kafka.server.KafkaRequestHandlers$$anonfun$handlerFor$5.apply(KafkaRequestHandlers.scala:47) at kafka.server.KafkaRequestHandlers$$anonfun$handlerFor$5.apply(KafkaRequestHandlers.scala:47) at kafka.network.Processor.handle(SocketServer.scala:289) at kafka.network.Processor.read(SocketServer.scala:312) at kafka.network.Processor.run(SocketServer.scala:207) at java.lang.Thread.run(Thread.java:680) {code} -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira