无所谓

怎么解决的 我也遇到了 求助

在哪能看到0.11的那个bug啊 那个bug是所有分区都会有问题还是某个分区会出问题呢 我们用的0.11.0.2版本

这么奇怪，而且就topic中的某一个分区才有问题。
我记得之前有看到kafka 0.10和0.11有类似的bug。

我不知道该怎么解决了。

没有这个策略

把相同的key进行压缩。

$ kafka-topics --create --zookeeper "zookeeper-0.zookeeper" --partitions 1 --replication-factor 1 --topic topicB --config cleanup.policy=compact
Created topic "topicB".

$ kafka-topics --describe --zookeeper "zookeeper-0.zookeeper" --topic topicB
Topic:topicB    PartitionCount:1    ReplicationFactor:1    Configs:cleanup.policy=compact
    Topic: topicB    Partition: 0    Leader: 1    Replicas: 1    Isr: 1

你描述下那个topic，看看是否有这个策略。