在我的风暴拓扑（有2个喷口和1个螺栓）的Kafka喷口消费之一的偏移是前进的，但msg不通过Kafka喷口发送到螺栓。我可以在storm ui中看到，对于那个特定的喷口，发射和传输的MSG是0。所以，我的问题是为什么消费者在进步，我可以看到消费者对zookeeper客户的补偿在逐渐增加。