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?
