title: Cannot compile Kafka consumer in Scala
body: <p>I want to consume messages from Kafka topic using Scala <code>2.10.6</code> and Spark <code>1.6.2</code>. For Kafka I am using this dependency:</p>
  
  <pre><code>&lt;dependency&gt;
       &lt;groupId&gt;org.apache.spark&lt;/groupId&gt;
       &lt;artifactId&gt;spark-streaming_2.10&lt;/artifactId&gt;
       &lt;version&gt;1.6.2&lt;/version&gt;
  &lt;/dependency&gt;
  </code></pre>
  
  <p>This code compiles fine, however I want to define <code>auto.offset.reset</code> and here the problem arises:</p>
  
  <pre><code>val topicMap = topic.split(",").map((_, kafkaNumThreads.toInt)).toMap
  val data = KafkaUtils.createStream(ssc, zkQuorum, group, topicMap,
                               StorageLevel.MEMORY_AND_DISK_SER_2).map(_._2)
  </code></pre>
  
  <p>When I add <code>kafkaParams</code>, it does not compile anymore:</p>
  
  <pre><code>val kafkaParams = Map[String, String](
  "zookeeper.connect" -&gt; zkQuorum, "group.id" -&gt; group,
  "zookeeper.connection.timeout.ms" -&gt; "10000",
  "auto.offset.reset" -&gt; "smallest")
  
  val data = KafkaUtils.createStream(ssc, kafkaParams, topicMap,
                                   StorageLevel.MEMORY_AND_DISK_SER_2).map(_._2)
  </code></pre>
  
  <p>Error message:</p>
  
  <pre><code>94: error: missing parameter type for expanded function ((x$3) =&gt; x$3._2)
  [ERROR]                                                 StorageLevel.MEMORY_AND_DISK_SER_2).map(_._2)
  </code></pre>
  
  <p>I tried many different cominations of parameters of <code>createStream</code>, but everything fails. Can someone help please? </p>