[ https://issues.apache.org/jira/browse/KAFKA-1968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14329902#comment-14329902 ]
Keith Bloomfield commented on KAFKA-1968: ----------------------------------------- Will do. Thanks. > 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()) {...} > passes 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)