我使用的是 kafka 版本：0.10.2.1，这个版本有一个已知问题。
https://issues.apache.org/jira/browse/KAFKA-5167
根据票证，它已在 0.10.2.2 和其他更高版本中修复。但是我没有看到 0.10.2.2 版本的任何 maven 依赖项。
没有 maven 工件，因为 kafka 0.10.2.2 尚未发布。
由于Kafka目前正在发布1.1，目前还不清楚0.10.2.2是否会发布。
您有 2 个选项：
-
通知开发者的邮件列表您对 0.10.2.2 感兴趣。如果有足够多的人感兴趣，它可能会发生
-
开始使用 0.10.2 分支。您必须自己构建它，但随后您将运行最新的 0.10.2 代码(包括 KAFKA-5167 的修复程序(。