nodefluent / kafka-streams

equivalent to kafka-streams :octopus: for nodejs :sparkles::turtle::rocket::sparkles:
https://nodefluent.github.io/kafka-streams/
MIT License
830 stars 111 forks source link

Using KTable for look-up with a KStream. #230

Closed chainhead closed 1 year ago

chainhead commented 2 years ago

I have two topics - rawData and lookUp where, rawData will receive data almost once per second and lookUp will be updated quite rarely e.g. once in a week or so. The rawData topic will be JSON data with say, {"customerID" : 124351, "data": ""} and lookUp will have JSON data say, {"customerID" : 124351, "flag": true}. The idea is to join rawData and lookUp on customerID to derive flag value that will rest of the other options.

Can you please show me an example?