Thanks Igor for the insights!
If you feel this should be changed, feel free to open a JIRA ticket.
Best,
Bruno
On 9/6/23 9:07 PM, Igor Maznitsa wrote:
Hi Bruno
Looks like that I have found error in my code. The error was that I
split create of StoreQueryParameters and my code looked like snippet below
/*var query = StoreQueryParameters.fromNameAndType(TABLE_NAME,
queryableStoreType);*/
/*if (useStale) {*/
/* query.enableStaleStore();
*/
*/}/
*
It was my mistake because I expected that the already existing instance
will be changed but it is immutable one and generates new instance. I
don't know why they have not made it as Builder pattern which would be
more appropriate one in the case imho.
I've made fix in my code
*/var query = StoreQueryParameters.fromNameAndType(TABLE_NAME,
queryableStoreType);/*
*/if (useStale) {/*
*/ query = query.enableStaleStore();
/*
*/}/*
and now it works well! thanks a lot for your help!
On 9/6/23 16:05, Bruno Cadonna wrote:
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?
