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 Fri, 18 Aug 2017 at 12:13 Duy Truong <ducduytruong2...@gmail.com> wrote:
> 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*
>
