Producer producer = new Producer(new ProducerConfig(props));
try {
for (byte[] message : monitorSet) {
KeyedMessage keyedMessage = new KeyedMessage(
"TrackingMonitoringEvent", message);
producer.send(keyedMessage);
}
} catch (Exception e) {
e.printStackTrace();
System.out.println(topic + " issue sending tracking to "
+ brokerList.toString());