downstream of tridentKafkaSpout

[Sa Li]

Hi, all

I have used tridentKafkaSpout to consume the json data from brokers, now I
like to write the newStream into postgresql. I notice there are dumperBolt
available to dump data into DB, but it is not for trident stream. I wonder
if I can combine trident stream with bolt or another way, say storm data in
hashmap and write it into DB in batch, and this will be implemented as
.each function?


thanks

Alec