Jon,
you can use Kafka's interactive queries feature for this:
http://docs.confluent.io/current/streams/developer-guide.html#interactive-queries
-Michael
On Thu, Mar 23, 2017 at 1:52 PM, Jon Yeargers
wrote:
> If I have an aggregation :
>
> KTable, VideoLogLine> outTable =
> sourceStream.grou
If I have an aggregation :
KTable, VideoLogLine> outTable =
sourceStream.groupByKey().reduce(rowReducer,
TimeWindows.of(60 * 60 * 1000L).until(10 * 60 * 1000L),
"HourAggStore");
how would I go about getting some value from this with a separate process?
I have the "
