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*