我使用的是ApacheStormCore0.9.6（它已经过时了，由于遗留问题而无能为力） KafkaSpout . 如果我可以记录元组偏移量，那么调试我所面临的反序列化问题将非常有帮助。
到目前为止我已经看到了 storm.kafka.KafkaUtils 有两种方法：

public static long getOffset(SimpleConsumer consumer, String topic, int partition, KafkaConfig config) 
public static long getOffset(SimpleConsumer consumer, String topic, int partition, long startOffsetTime)

第一个是第二个的 Package 。在我看来，我唯一不知道如何调用这个函数的是 consumer . 我读过这本书 KafkaSpout 代码并没有弄清楚如何从中获得Kafka消费者。