采纳
我看了一下https://issues.apache.org/jira/browse/KAFKA-6610和https://github.com/apache/kafka/pull/4695具体没太看懂。好像说是让1.1解决了这个问题。但我没看到有补丁,是不是说直接升级。如果升级原来的数据还存在吗?