Thanks for the pointer .. I finally figured it out .. Now I am facing
another issue with custom state store - sent a different mail on the forum.
regards.
On Fri, Jun 30, 2017 at 11:12 PM, Damian Guy wrote:
> Hi Debasish,
>
> You can just implement the QueryableStoreType interface. You can take
Hi Debasish,
You can just implement the QueryableStoreType interface. You can take a
look here:
https://github.com/apache/kafka/blob/trunk/streams/src/main/java/org/apache/kafka/streams/state/QueryableStoreTypes.java#L77
for
an example.
Then you just pass your implementation to `kafkaStreams.stor
Hi -
I have a custom state store in my Kafka Streams application. I have
developed the whole Topology and the Processor abstractions. I have the
custom state store implemented as well and have the following builder for
hooking up the processors and the store .. Here's the Scala snippet ..
builder
