Hi Igor,
Sorry to hear you have issues with querying standbys!
I have two questions to clarify the situation:
1. Did you enable querying stale stores with
StoreQueryParameters.fromNameAndType(TABLE_NAME,
queryableStoreType).enableStaleStores()
as described in the blog post?
2. Since you are querying a stale store, could it be the the standby
hasn't caught up yet?
Best,
Bruno
On 9/6/23 8:32 AM, Igor Maznitsa wrote:
Hello
1. I am starting two Kafka Streams applications worked in same group
with num.standby.replicas=1
2. Application A has active TimeWindow data store and application B has
the standby version of the data store
Is there any way to read the standby store time window data in bounds of
B application?
I found some examples (like
https://www.confluent.io/blog/kafka-streams-ksqldb-interactive-queries-go-prime-time/) and tests but all they use KeyValue stores. I made some experiments but got empty fetch on standby node for same key and time interval which returns windows on the active node. Is there any restriction and such mechanism works only for KeyValue stores?
