Hello, I have a deployment with several topologies and, from time to time, one of them is stuck in an infinite loop. In this case, kafka-spout emits always the same tuple (or batch of tuples).
Until now, i usually clean kafka directories, even storm directories. This solution is quite drastic, because it results in data loss. But i cannot find another solution. Is there any problem with my OpaqueTridentKafkaSpout configuration? Here is my code: ZkHosts brokerHosts = new ZkHosts(zookeepers); TridentKafkaConfig kafkaConfig = new TridentKafkaConfig(brokerHosts, KAFKATOPIC); kafkaConfig.scheme = new SchemeAsMultiScheme(new OperationBigDecimalProtobuffScheme()); OpaqueTridentKafkaSpout kafkaSpout = new OpaqueTridentKafkaSpout(kafkaConfig); Any suggestions? Thanks in advance
