Jiangjie Qin created KAFKA-3189: ----------------------------------- Summary: Kafka server always return UnknownServerException. Key: KAFKA-3189 URL: https://issues.apache.org/jira/browse/KAFKA-3189 Project: Kafka Issue Type: Bug Reporter: Jiangjie Qin
This issue was introduced in KAFKA-2929. The problem is that we are using o.a.k.common.protocol.Errors.forException() while all exceptions thrown by the broker are still using old scala exception. This cause Errors.forException() always return UnknownServerException. We should either switch back to Errors.forException() to ErrorMapping.codeFor() or migrate all the exceptions to Java exception. I prefer the latter option since it seems to be a simple class replacement. -- This message was sent by Atlassian JIRA (v6.3.4#6332)