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*

Reply via email to