public static StringConsumers buildConsumer ( final String zookeeperConfig , // final String topic , // final String groupId , // final IMessageListener < String > listener ) { return buildConsumer ( zookeeperConfig , topic , groupId , listener , 2 ) ; }
create a consumer