Open nandanrao opened 5 years ago
Should basically just:
kafka = setup kafka
stream.on('data', msg => db.put(msg.key.toString(), msg.value.toString()))
For generic db.put(k,v) >> which should push to list with key k or add to table a k,v pair.
db is the implemented by chatbase wrappers
Should basically just:
kafka = setup kafka
For generic db.put(k,v) >> which should push to list with key k or add to table a k,v pair.
db is the implemented by chatbase wrappers