You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "David Arthur (JIRA)" <ji...@apache.org> on 2012/09/21 18:19:07 UTC
[jira] [Created] (KAFKA-523) OffsetRequest handler does not handle
errors
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
[jira] [Updated] (KAFKA-523) OffsetRequest handler does not handle
errors
Posted by "David Arthur (JIRA)" <ji...@apache.org>.
[ 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
[jira] [Comment Edited] (KAFKA-523) OffsetRequest handler does not
handle errors
Posted by "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
[jira] [Updated] (KAFKA-523) OffsetRequest handler does not handle
errors
Posted by "David Arthur (JIRA)" <ji...@apache.org>.
[ 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
[jira] [Commented] (KAFKA-523) OffsetRequest handler does not
handle errors
Posted by "Joel Koshy (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/KAFKA-523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13460627#comment-13460627 ]
Joel Koshy commented on KAFKA-523:
----------------------------------
This will be addressed as part of KAFKA-501. It requires a wire-format change though so it will be in 0.8.
> 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
[jira] [Comment Edited] (KAFKA-523) OffsetRequest handler does not
handle errors
Posted by "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}
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
[jira] [Updated] (KAFKA-523) OffsetRequest handler does not handle
errors
Posted by "David Arthur (JIRA)" <ji...@apache.org>.
[ 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.
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}
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