Update: There is a better way to do this, please see a more recent post here.
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 