我正在使用kafka simpleconsumer的一个修改版本来向rest api公开偏移量，基于：https://cwiki.apache.org/confluence/display/kafka/0.8.0+simpleconsumer+example
但是，该示例的行为与shell命令不一致：./kafka-run-class.sh kafka.tools.consumeroffsetchecker。。。
在这种情况下，有时它可以工作，有时它成功地返回一个嵌入的错误。换句话说，支票：
if（response.haserror（））{…}
完全没有用，因为响应（据它所知）没有错误。但如果我去拜访：
response.tostring（）.contains（“错误”）
当然，响应中有一个错误。错误是：
Kafka.公共.未知异常
所以它不知道它有一个错误，一旦异常被拉出，它就以idonknowwhatwentforleexception的形式表示。再加上这样一个事实：对于一个可以说更复杂的对象（讽刺地称为“简单”消费者），这种情况会间歇性发生，而且闻起来很可疑。
我是不是漏掉了什么明显的东西？这是已知的问题吗？
如果我得到asf的回复，我会在这里发布解决方案。谢谢。