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
