Hi @Randy Gelhausen, I tried this method, It works fine if you have a kafka topic with single partition, but when I try to ingest messages into a kafka topic with two partitions, only one of the partiton is being hit. Could you suggest a way to ingest messages in multiple partitions. ... View more