// initialize kafka producer to generate count events
String nodePath = KafkaETLCommons.getNodesPath(_props);
System.out.println("node path=" + nodePath);
Props nodesProps = KafkaETLUtils.readProps(nodePath);
_producers = new ArrayList<SimpleProducer>();
for (String key : nodesProps.stringPropertyNames()) {
URI uri = nodesProps.getUri(key);
System.out.println("server uri:" + uri.toString());
_producers.add(new SimpleProducer(uri.getHost(), uri.getPort(),
TCP_BUFFER_SIZE, CONNECT_TIMEOUT, RECONNECT_INTERVAL));
}