How to get data from kafka producer by tranquility and save to druid?

Hello Everyone,

I want to generate data from other resources automatically but not manually type into console. I wrote a producer.java and generate data like

{“unit”: “milliseconds”, “http_method”: “GET”, “value”: 28, “timestamp”: “2017-07-14T07:27Z”, “http_code”: “200”, “page” : “/get/28/”, “metricType”: “request/latency”, “server”: www5.example.com"}

I’ve already start my zookeeper, kafka, tranquility, and druid. It’s all works well by typing these message to producer console. These messages can saved to druid successfully, but not work while I want to do by my producer.java. Anyone help?