Im probing about trying to find a way to solve my aggregation -> db issue. Looking at the '.fetch()' function Im wondering about the 'timeFrom' and 'timeTo' params as not a lot is mentioned about 'proper' usage.
The test in https://github.com/confluentinc/examples/blob/master/kafka-streams/src/test/java/io/confluent/examples/streams/interactivequeries/WordCountInteractiveQueriesExampleTest.java#L200-L212 makes it appear that the params are boundaries and that it will return an inclusive list of every key/window combination. Truth? My tests to this end haven't returned anything. Im watching the values coming out of the KTable<Window, String> so I can send them back as request params. What Ive tried: - Window.key(), Window.key().start() and Window.key().end() - Window.key(), (Window.key().start() - 1) and (Window.key().end() + 1) - Window.key(), 0 and Window.key().end() - Window.key(), 0 and (Window.key().end() + 1) None of these seem to hit anything in the StateStore. Is there a delay before Store values become available for '.fetch()'?
