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

[David Arthur (JIRA)]

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