我正在使用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个选择: