I've written a Streams application which creates a KTable like this:
val myTable: KTable[String, GenericRecord] = myStream
.groupByKey()
.aggregate(myInitializer, myAdder, myStore)
where myStore was configured like this:
val myStore
: Materialized[String, GenericRecord, KeyValueStore
e this Store with a say REST or any other RPC interface, to let
> applications from outside your JVM query it.
>
> So i would say the blogpost still applies quite well.
>
> Hope this helps
>
> Best Jan
>
>
> On 07.12.2017 04:59, Peter Figliozzi wrote:
>
>> I&#x
Hello Kafka Users,
I started using Kafka a couple of weeks ago an am very impressed! I've
gotten the hang of producing, and now it's time for consuming. My
applications (Scala) don't work quite like the examples, but I think it's a
pretty basic architecture:
- Suppose you have a several top
