[jira] [Comment Edited] (KAFKA-523) OffsetRequest handler does not handle errors

["David Arthur (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/KAFKA-523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13460593#comment-13460593 ] 

David Arthur edited comment on KAFKA-523 at 9/22/12 3:21 AM:
-------------------------------------------------------------

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}

                
      was (Author: mumrah):
    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}
test
{code}

{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}
                  
> 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.

--
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