title: spark-streaming-kafka-0-10 auto.offset.reset is always set to none
body: <p>Does anyone come across the issue when assign auto.offset.reset->"latest" doesn't affect this property in spark-streaming-kafka 0-10</p>
  
  <p>here is my code:</p>
  
  <pre><code> val config = StreamingConfigHelper.getStreamingConfig()
  val kafkaParams = Map[String, Object]("bootstrap.servers" -&gt; config.brokers,
    "key.deserializer" -&gt; classOf[ByteArrayDeserializer],
    "value.deserializer" -&gt; classOf[ByteArrayDeserializer],
    "group.id" -&gt; "prodgroup",
    "auto.offset.reset" -&gt; "latest",
    "receive.buffer.bytes" -&gt; (65536: java.lang.Integer),
    "enable.auto.commit" -&gt; (false: java.lang.Boolean))
  val inputDStream = KafkaUtils.createDirectStream[Array[Byte], Array[Byte]](streamingContext, LocationStrategies.PreferConsistent,
    ConsumerStrategies.Subscribe[Array[Byte], Array[Byte]](config.productTopic.toArray, kafkaParams))
  </code></pre>
  
  <p>But when I deploy I get this results</p>
  
  <pre><code>16/11/11 11:03:00 INFO ConsumerConfig: ConsumerConfig values: 
  metric.reporters = []
  metadata.max.age.ms = 300000
  partition.assignment.strategy = [org.apache.kafka.clients.consumer.RangeAssignor]
  reconnect.backoff.ms = 50
  sasl.kerberos.ticket.renew.window.factor = 0.8
  max.partition.fetch.bytes = 1048576
  bootstrap.servers = [xxxxxxxxx:6667, xxxxxxxx:6667, xxxxxxxxxx:6667]
  ssl.keystore.type = JKS
  enable.auto.commit = false
  sasl.mechanism = GSSAPI
  interceptor.classes = null
  exclude.internal.topics = true
  ssl.truststore.password = null
  client.id = 
  ssl.endpoint.identification.algorithm = null
  max.poll.records = 2147483647
  check.crcs = true
  request.timeout.ms = 40000
  heartbeat.interval.ms = 3000
  auto.commit.interval.ms = 5000
  receive.buffer.bytes = 65536
  ssl.truststore.type = JKS
  ssl.truststore.location = null
  ssl.keystore.password = null
  fetch.min.bytes = 1
  send.buffer.bytes = 131072
  value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
  group.id = spark-executor-prodgroup1
  retry.backoff.ms = 100
  sasl.kerberos.kinit.cmd = /usr/bin/kinit
  sasl.kerberos.service.name = null
  sasl.kerberos.ticket.renew.jitter = 0.05
  ssl.trustmanager.algorithm = PKIX
  ssl.key.password = null
  fetch.max.wait.ms = 500
  sasl.kerberos.min.time.before.relogin = 60000
  connections.max.idle.ms = 540000
  session.timeout.ms = 30000
  metrics.num.samples = 2
  key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
  ssl.protocol = TLS
  ssl.provider = null
  ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
  ssl.keystore.location = null
  ssl.cipher.suites = null
  security.protocol = PLAINTEXT
  ssl.keymanager.algorithm = SunX509
  metrics.sample.window.ms = 30000
  auto.offset.reset = none
  </code></pre>
  
  <p>Could you help please?
  Thanks</p>