Address the comment to remove the resetOffset() function

external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaUtils.scala

@@ -17,22 +17,19 @@
 
 package org.apache.spark.streaming.kafka
 
+import java.lang.{Integer => JInt}
+import java.util.{Map => JMap}
 
 import scala.reflect.ClassTag
 import scala.collection.JavaConversions._
 
-import java.lang.{Integer => JInt}
-import java.util.{Map => JMap}
-
 import kafka.serializer.{Decoder, StringDecoder}
-import kafka.utils.ZkUtils
 
 import org.apache.spark.storage.StorageLevel
 import org.apache.spark.streaming.StreamingContext
 import org.apache.spark.streaming.api.java.{JavaPairReceiverInputDStream, JavaStreamingContext}
 import org.apache.spark.streaming.dstream.ReceiverInputDStream
 
-
 object KafkaUtils {
   /**
    * Create an input stream that pulls messages from a Kafka Broker.
@@ -147,23 +144,4 @@ object KafkaUtils {
     createStream[K, V, U, T](
       jssc.ssc, kafkaParams.toMap, Map(topics.mapValues(_.intValue()).toSeq: _*), storageLevel)
   }
-
-  /**
-   * Delete the consumer group related Zookeeper metadata immediately,
-   * force consumer to ignore previous consumer offset and directly read data from the beginning
-   * or end of the partition. The behavior of reading data from the beginning or end of the
-   * partition also relies on kafka parameter 'auto.offset.reset':
-   * When 'auto.offset.reset' = 'smallest', directly read data from beginning,
-   * will re-read the whole partition.
-   * When 'auto.offset.reset' = 'largest', directly read data from end, ignore old, unwanted data.
-   * This is default in Kafka 0.8.
-   *
-   * To avoid deleting existing Zookeeper metadata in each Receiver when multiple consumers are
-   * launched, this should be called be createStream().
-   * @param zkQuorum Zookeeper quorum (hostname:port,hostname:port,..).
-   * @param groupId The group id for this consumer.
-   */
-  def resetOffset(zkQuorum: String, groupId: String) {
-    ZkUtils.maybeDeletePath(zkQuorum, s"/consumers/$groupId")
-  }
 }