Keith Bloomfield created KAFKA-1968:
---------------------------------------
Summary: SimpleConsumer succeeds with embedded failure message
Key: KAFKA-1968
URL: https://issues.apache.org/jira/browse/KAFKA-1968
Project: Kafka
Issue Type: Bug
Components: clients
Affects Versions: 0.8.1.1
Environment: javaapi on Java 6
Reporter: Keith Bloomfield
I am using a modified version of the Kafka SimpleConsumer to expose offsets to
a rest api, based on:
https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example
However, the behavior of the example is inconsistent with the shell command:
./kafka-run-class.sh kafka.tools.ConsumerOffsetChecker ...
In that sometimes it works, and sometimes it returns successfully with an
embedded error. In other words, the check:
if (response.hasError()) {...}
is entirely useless because the response (as far as it's aware) has no error.
But if I drop in a:
response.toString().contains("error")
then sure enough, there is an error in the response. The error is:
kafka.common.UnknownException
Not sure what is happening in Kafka to result in this behavior.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
