protected ConsumerConnector createConsumerConnector(Properties consumerProperties){
  return Consumer.createJavaConsumerConnector(new kafka.consumer.ConsumerConfig(consumerProperties));
}

protected ConsumerConnector createConsumerConnector ( Properties consumerProperties ) { return Consumer . createJavaConsumerConnector ( new kafka . consumer . ConsumerConfig ( consumerProperties ) ) ; }
create a kafka consumer connector from the given properties .
