Subject: Reg : kafka state store HA


Not exactly sure what your code does. But note, that state stores are
sharded and you need to query the right shard (ie, instance).

I would recommend to read:
https://www.confluent.io/blog/unifying-stream-processing-and-interactive-queries-in-apache-kafka/

There is also a blog post that explains it:
https://www.confluent.io/blog/unifying-stream-processing-and-interactive-queries-in-apache-kafka/

Last, there is a Kafka Summit talk:
https://www.confluent.io/kafka-summit-sf17/Interactive-Queries-in-Kafka-Streams-API
Hope this helps.
-Matthias

On 11/17/19 8:49 PM, Penumarthi Durga Prasad Chowdary wrote:
Comment: GPGTools - https://gpgtools.org

iQIzBAEBCgAdFiEE8osu2CcCCF5douGQu8PBaGu5w1EFAl3SS/MACgkQu8PBaGu5
w1G/9A//YUpXGi+6bfhDFxhcFjoPDbStg0NkCHrcVG37wTMuSc6lNvf6U9Cg+LJK
jX0I0r7aZLAhEAg847Ql90C37bkdGtSqUTV9bsOVzkd1F34btK3Tf4GpaQjjO/41
Z6L+EddmDfyXdh1g2xpXd1NBsqcjt+7WKdz18QXvS+hPJeYBBHbNwPEGtNzItEhN
IH3+Qg3e2kxEtVpNYXMc6pJdNGcCke7c5hl1hjARrPHJquY6loIJVF+C+6dPWRk5
dLhLmXGfxF2LWA35Efgk4BQAmLjVzuPRHXPxM7yxE17KrI6rghi8Y2x+j2COFc0z
EGL/uCa8cRAwnfe3a4H+k/ebxSLAlt9Dn0wrbKGhNhS7s8ntyrc3vX4RTxSwvPld
qQCWkIzs2x4CDW6EpfejqF2Bo5qVj6Hdz3SCRJzKULTGtqH24jRdDpjxgeY13NwM
kvABQrQAMY2/r9GPdQvmBqI8h9ZookPvS2vTzD2l+QOtAxmLIk9UCt/enSkt/gCD
bzaSuU0Yrqffx47/4uYatAvX5P9zS/9xdEFyUHox94PJM0iaFf+0Dnjkl+HIurjQ
OMFFvRF/jwfUOYCOgc5I4OI7gtJd+lURsDlpN69jMHvvZHRCURyAEpS+gib/wm/y
ZN33KqU62/XGnryFmacYS6Lh7WElcITUhhUvcbhskZQYWKwhYZw=
=J22D
-----END PGP SIGNATURE-----