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 code to build the table: val userTable: GlobalKTable[String, UserData] = builder.globalTable(Serdes.String(), userDataSede, userTopic, userDataStore) data in kafka topic is serialized in avro format. Do you have any suggestions? Thanks On Fri, Aug 18, 2017 at 6:23 PM, Damian Guy <damian....@gmail.com> wrote: > 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* > > > -- *Duy Truong*