[
https://issues.apache.org/jira/browse/KAFKA-523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur updated KAFKA-523:
-------------------------------
Description:
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}
was:
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}
> 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
