public DmaapConsumerWrapper(List<String> servers, String topic,
String aafLogin, String aafPassword,
String consumerGroup, String consumerInstance,
- int fetchTimeout, int fetchLimit) throws MalformedURLException{
+ int fetchTimeout, int fetchLimit) throws MalformedURLException{
this.consumer = new MRConsumerImpl(servers, topic,
consumerGroup, consumerInstance,
/**
* {@inheritDoc}
*/
+ @Override
public Iterable<String> fetch() throws MRApiException {
try {
return this.consumer.fetch();
/**
* {@inheritDoc}
*/
+ @Override
public void close() {
this.consumer.close();
}