remove registerConsumerForJMX() method as not needed

Author: ppine7

README.md

@@ -22,8 +22,11 @@ Currently, an example implemented destination is ElasticSearch. One batch of mes
 
 * starting offset positions can be specified via configuration properties
 * IConsumerWorker interface-based consumers allow you to :
+
 ** customize how offsets are exposed to other systems - like JMX/monitoring or external storage
+
 ** customize when offsets are committed to Kafka - allowing you to specify your own logic/rules for re-processing of potentially failed events/batchs
+
 * IBatchMessageProcessor interface-based batch processors can be customized to process each batch of messages into any destination 
 
 

src/main/java/org/elasticsearch/kafka/indexer/jobs/ConsumerWorker.java

@@ -13,7 +13,6 @@
 
 import javax.annotation.Resource;
 
-import org.apache.commons.lang3.StringUtils;
 import org.apache.kafka.clients.consumer.ConsumerConfig;
 import org.apache.kafka.clients.consumer.ConsumerRecord;
 import org.apache.kafka.clients.consumer.ConsumerRecords;
@@ -28,8 +27,6 @@
 import org.elasticsearch.kafka.indexer.service.IBatchMessageProcessor;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.ObjectFactory;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 
 public class ConsumerWorker implements AutoCloseable, IConsumerWorker {
@@ -70,7 +67,6 @@ public void initConsumerInstance(int consumerInstanceId) {
         kafkaProperties.put(ConsumerConfig.CLIENT_ID_CONFIG, consumerClientId);
         kafkaProperties.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");
         consumer = new KafkaConsumer<>(kafkaProperties);
-        registerConsumerForJMX();
         logger.info(
             "Created ConsumerWorker with properties: consumerClientId={}, consumerInstanceName={}, kafkaTopic={}, kafkaProperties={}",
             consumerClientId, consumerInstanceName, kafkaTopic, kafkaProperties);        
@@ -162,10 +158,6 @@ public void exposeOffsetPosition(Map<TopicPartition, OffsetAndMetadata> previous
         // NO OP
     }
 
-    public void registerConsumerForJMX() {
-        // NO OP
-    }
-   
     private void commitOffsetsIfNeeded(boolean shouldCommitThisPoll, Map<TopicPartition, OffsetAndMetadata> partitionOffsetMap) {
         try {
             if (shouldCommitThisPoll) {

src/main/java/org/elasticsearch/kafka/indexer/jobs/IConsumerWorker.java

@@ -17,13 +17,7 @@ public interface IConsumerWorker extends Runnable {
      * @param previousPollEndPosition
      */
     public void exposeOffsetPosition(Map<TopicPartition, OffsetAndMetadata> previousPollEndPosition);
-    
-    /**
-     * this method can be overwritten in a custom implementation of the Consumer - 
-     * to register this consumer with a JMX exporting service
-     */
-    public void registerConsumerForJMX();
-    
+        
     /**
      * Creates Kafka properties and an instance of a KafkaConsumer
      *