We have a requirement where json documents are being pushed to some kafka topics. We have to pull these docs and map it to postgresql db tables. So we have a DI job to do this mapping but we have to keep running this job to fetch from kafka topic. Is there any way to trigger the job whenever some doc comes in kafka topic for the specific group?
As the interval of documents being pushed to kafka is not fixed.
