public MessageSenderPool(int size, String topic, ZkHosts zkhosts, Properties props) needs a correct props input

[eskuai]

In line 111, i think , a props as input parameters is needed.

public MessageSenderPool(int size, String topic, ZkHosts zkhosts, Properties props)
<...>
new DynamicBrokersReader(conf, zkhosts.getBrokerZkStr(), zkhosts.getBrokerZkPath(), topic);
this.brokerStr = reader.getBrokerInfo();
this.props = new Properties(); // maybe new Properties(props)
this.props.put(KafkaConstants.BROKER_LIST, this.brokerStr);
init();
}