as the https://github.com/apache/storm/tree/master/external/storm-kafka#brokerhosts says,
When re-deploying a topology make sure that the settings for SpoutConfig.zkRoot and SpoutConfig.idwere not modified, otherwise the spout will not be able to read its previous consumer state information (i.e. the offsets) from ZooKeeper -- which may lead to unexpected behavior and/or to data loss, depending on your use case. But I use trident, the TridentKafkaConfig does not have the id and zkRoot properties. So where is the offset of a trident topo? Is it in : zk: localhost:2181(CONNECTED) 61] get /transactional/mytopic/coordinator/currtx 69022 cZxid = 0x10215db19 ctime = Wed Jul 08 12:49:34 HKT 2015 mZxid = 0x102274a3b mtime = Wed Jul 08 16:46:18 HKT 2015 pZxid = 0x10215db19 cversion = 0 dataVersion = 69126 aclVersion = 0 ephemeralOwner = 0x0 dataLength = 5 But the 69022 is a txid, how can I get the offset time? thanks. Jinhong Lu
