Hi Damian,
I've checked the global table and found that there is no data in the table,
here is my code to check:
val view: ReadOnlyKeyValueStore[String, UserData] =
jvnStream.store("userdata", QueryableStoreTypes.keyValueStore[String,
UserData]())
view.all().foreach((kv) => kv.toString)
And the
Hi,
If the userData value is null then that would usually mean that there
wasn't a record with the provided key in the global table. So you should
probably check if you have the expected data in the global table and also
check that your KeyMapper is returning the correct key.
Thanks,
Damian
On
Hi everyone,
When using left join, I can't get the value of Global KTable record in
ValueJoiner parameter (3rd parameter). Here is my code:
val userTable: GlobalKTable[String, UserData] =
builder.globalTable(Serdes.String(), userDataSede, userTopic, userDataStore)
val jvnStream: KStream[String,
