How do we specify zookeeper config to OpaqueTridentKafkaSpout Saw the below answer earlier: Can someone elaborate on this ? Use the transactional.zookeeper.* configs to configure this.
What is happening is messages pushed in Kafka while topology was down are not read by spout when topology comes up. Please help, Thanks. Regards, Amber Kulkarni