spark-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ted Yu <yuzhih...@gmail.com>
Subject Re: KafkaUtils.createStream(..) is removed for API
Date Mon, 19 Feb 2018 01:47:31 GMT
createStream() is still
in external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/KafkaUtils.scala
But it is not
in external/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/KafkaUtils.scala

FYI

On Sun, Feb 18, 2018 at 5:17 PM, naresh Goud <nareshgoud.dulam@gmail.com>
wrote:

> Hello Team,
>
> I see "KafkaUtils.createStream() " method not available in spark 2.2.1.
>
> Can someone please confirm if these methods are removed?
>
> below is my pom.xml entries.
>
>
> <properties>
>   <scala.version>2.11.8</scala.version>
>   <scala.tools.version>2.11</scala.tools.version>
> </properties>
>
>
>   <dependency>
>       <groupId>org.apache.spark</groupId>
>       <artifactId>spark-streaming_${scala.tools.version}</artifactId>
>       <version>2.2.1</version>
>       <scope>provided</scope>
>   </dependency>
> <dependency>
>   <groupId>org.apache.spark</groupId>
>   <artifactId>spark-streaming-kafka-0-10_2.11</artifactId>
>   <version>2.2.1</version>
>   <scope>provided</scope>
> </dependency>
> <dependency>
>   <groupId>org.apache.spark</groupId>
>   <artifactId>spark-core_2.11</artifactId>
>   <version>2.2.1</version>
>   <scope>provided</scope>
> </dependency>
>   <dependency>
>
>
>
>
>
> Thank you,
> Naresh
>

Mime
View raw message