You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Neha Narkhede (JIRA)" <ji...@apache.org> on 2015/02/20 05:47:11 UTC

[jira] [Resolved] (KAFKA-1968) SimpleConsumer succeeds with embedded failure message

     [ https://issues.apache.org/jira/browse/KAFKA-1968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Neha Narkhede resolved KAFKA-1968.
----------------------------------
    Resolution: Not a Problem

This is easier to discuss on the mailing list first to determine if it is a bug or not. Feel free to reopen if we determine it is a problem through the mailing list discussion

> 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)