Where can I find an example of indexing data into Druid using its Java API?
Basically, my input data comes from Kafka. It is then transformed by a Java application and pushed into a second dedicated Kafka topic. This topic is consumed by a Druid realtime node. I would like to eliminate the need for the second Kafka topic and have the Java application insert into Druid directly. How do I do this? Alternatively, is there a way of plugging data transformations/filters into the realtime node setup?