Hi,
I have a topology that stuck processing messages and in order to
troubleshoot I want to see or remove offset in zookeeper. The problem is I
can find any offset for my topic / client. I checked all zookepper nodes
and it's not there. Where OpaqueTridentKafkaSpout should keep offset?
my topology:
BrokerHosts brokerHosts = new ZkHosts(".....");
TridentTopology topology = new TridentTopology();
TridentKafkaConfig spoutConfig = new TridentKafkaConfig(
brokerHosts,
"batch_processing_events",
"batch_processing_event_client");
spoutConfig.scheme = new SchemeAsMultiScheme(new EventStringScheme());
OpaqueTridentKafkaSpout spout = new OpaqueTridentKafkaSpout(spoutConfig);
Stream inputStream=topology.newStream("offlineEvents", spout)
In zookeeper I am looking for "batch_processing_event_client" but it's not
exist in consumer or transactional:
ls /
[transactional, clusterstate.json, consumers, storm, controller_epoch,
configs, admin, zookeeper, aliases.json, config, controller, live_nodes,
overseer, brokers, collections, overseer_elect]
[zk: localhost:2181(CONNECTED) 1] ls /consumers
[fullindexer, kafkatest, testgroup, deltaindexer, search-content-loader,
mytest]
[zk: localhost:2181(CONNECTED) 2] ls /transactional
[offlineEvents]
Thanks
Eugene.