这个问题在新版本修复了。
https://issues.apache.org/jira/browse/KAFKA-6188