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, JVNModel] = sourceStream.leftJoin(userTable,
(eventId: String, dataLog: DataLog) => {
dataLog.rawData.userId
},
(dataLog, userData: UserData) => {
// userData is null.
})
What I have to do to resolve this issue?
Thanks
--
*Duy Truong*