Github user lw-lin commented on a diff in the pull request:
https://github.com/apache/spark/pull/15681#discussion_r85640495
--- Diff:
external/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/KafkaUtils.scala
---
@@ -56,32 +57,18 @@ object KafkaUtils extends Logging {
Github user lw-lin commented on a diff in the pull request:
https://github.com/apache/spark/pull/15681#discussion_r85640467
--- Diff:
external/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/KafkaUtils.scala
---
@@ -56,32 +57,18 @@ object KafkaUtils extends Logging {
Github user lw-lin commented on a diff in the pull request:
https://github.com/apache/spark/pull/15681#discussion_r85640450
--- Diff:
external/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/KafkaUtils.scala
---
@@ -56,32 +57,18 @@ object KafkaUtils extends Logging {
Github user lw-lin commented on a diff in the pull request:
https://github.com/apache/spark/pull/15681#discussion_r85640442
--- Diff:
external/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/DirectKafkaInputDStream.scala
---
@@ -44,11 +44,6 @@ import
org.apache.spar
GitHub user lw-lin opened a pull request:
https://github.com/apache/spark/pull/15681
[Minor][Streaming][Kafka] Kafka010 .createRDD() scala API should expect
scala Map
## What changes were proposed in this pull request?
Thoughout `external/kafka-010`, Java APIs are expecting
