Hi Jon, This will be a windowed store. Have a look at the Jetty-server bits for windowedByKey: "/windowed/{storeName}/{key}/{from}/{to}"
Thanks Eno > On 6 Dec 2016, at 23:33, Jon Yeargers <jon.yearg...@cedexis.com> wrote: > > I copied out some of the WordCountInteractive > <https://github.com/confluentinc/examples/blob/3.1.x/kafka-streams/src/main/java/io/confluent/examples/streams/interactivequeries/WordCountInteractiveQueriesExample.java> > demo > code to see how the REST access works. I have an aggregator > > groupByKey().aggregate(LogLine::new, > new aggregate(), > TimeWindows.of(60 * 60 * 1000L), > collectorSerde, "agg_stream"); > > > I incorporated the Jetty-server bits from the sample. When I run it I can > see results via the '/states/instances' entry point but nothing from the > '/states/keyvalues/agg_stream/all'. > > The aggregator is churning away so I'd assume the state store would have > plenty of key/value pairs but it comes up empty. > > What's the proper way to use this?