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.du...@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 >