Hello, I am using low level processor and I set the context.schedule(10000), assuming that punctuate() method is invoked every 10 sec . I have set configProperties.put(StreamsConfig.TIMESTAMP_EXTRACTOR_CLASS_CONFIG, WallclockTimestampExtractor.class.getCanonicalName()) )
Although data is keep coming to the topology (as I have logged the incoming tuples to process() ), punctuate() is never executed. What I am missing? best, Shahab
