Recently I was tasked with depositing ingested events to one or more Kafka topics, based upon routing configuration. We’re using Quarkus. Here is the class which does the work:
Multicasting Events to Kafka Topics
Recently I was tasked with depositing ingested events to one or more Kafka topics, based upon routing configuration. We’re using Quarkus. Here is the class which does the work:
Beyond Velocity 