score:1
Accepted answer
If you are using spark-streaming-kafka-0-10_2.11-2.3.0 jar
then the KafkaUtils is available in org.apache.spark.streaming.kafka010
this package.
So import
import org.apache.spark.streaming.kafka010.KafkaUtils
and not
import org.apache.spark.streaming.kafka.kafkautils
Hope this hepls!
Source: stackoverflow.com
Related Query
- Am getting error in scala programming while integrating spark streaming with kafka
- Getting connection error while reading data from ElasticSearch using apache Spark & Scala
- Getting error `No implicits found for parameter fieldMapper: FieldMapper` while using Squeryl version 0.9.14 with Scala version 2.13.1
- Error while Executing Scala constructs with Spark 1.5.2 and Scala 2.11.7
- Getting error while defining schema for csv file in spark using scala
- Error on integrating Spark with Scala project in IntelliJ IDE
- Getting Error While Creating JAR from the SPARK SCALA MAVEN Project in Eclipse IDE
- Error while reading an Excel file using Spark Scala with filename as a parameter
- Why I am getting below error while I am writing a code in scala to run a spark application?
- Why I am getting below error while I am writing a code in scala to run a spark application?
- Scala Spark Streaming unit test with spark-testing-base throws error
- I am getting error in eclipse while running Spark WordCount in scala
- Getting Error while connection with ElasticSearch in Spark Streamming
- Getting an error while trying to run a simple spark streaming kafka example
- Why am I getting this error when running Scala 2.13 tests in IntelliJ, but not with Scala 2.12?
- 'Connection Refused' error while running Spark Streaming on local machine
- Multiple constructors with the same number of parameters exception while transforming data in spark using scala
- Spark Streaming Saving data to MySQL with foreachRDD() in Scala
- Getting error like need struct type but got string in spark scala for simple struct type
- scala worksheet throwing error with spark
- Apache Spark Mllib 2.1.0 with Scala sbt error
- Error while adding a new utf8 string column to Row in Scala spark
- Error while reading a CSV file in Spark - Scala
- Error while reading very large files with spark csv package
- Facing error while extending scala class with Product interface to overcome limit of 22 fields in spark-shell
- running jupyter + Apache Toree 0.2.0 with spark 2.2 kernel generate error (Missing dependency 'object scala in compiler mirror')
- Eclipse error with scala / spark project
- While using udf function getting error "Validation$$anonfun$14 cannot be cast to scala.Function5" in scala
- Getting out of memory error while reading parquet file in spark submit job
- i want to store each rdd into database in twitter streaming using apache spark but got error of task not serialize in scala
More Query from same tag
- Convert Date String to Day in Scala
- Scala Seq - accept only elements of the same subtype
- Scala and parameters of unapply function
- How to find length of query in slick and use it as a boolean?
- Imported 3rd party library from SBT can't find package
- Cats Monad Transformers
- Scala - extracting first element of inner array of strings from nested arrays of strings
- Dynamic parameter in Scala template for PlayFramework
- Error trying to run Scala Application inside Eclipse
- How to get a Long typed production of a Seq[Int] in Scala?
- Why can't I serialize Map[String,Any] to JSON?
- Squeryl dynamic join clauses
- How to use the Scala import clause to import from a method parameter
- Scala - can a lambda parameter match a tuple?
- Gatling Error when running multiple users - 'httpRequest-2' failed to execute: No attribute named 'access_token' is defined
- How does tell() work in Akka actor system?
- Connecting AXI Stream to StreamFifo
- "$centerSphere" query in reactivemongo
- Abstract methods and the varargs annotation
- How to read a temporary view created with Scala using R in Databricks?
- Writing functional code, example of find function
- How do I take a subset of a Vector by a Vector-of-indexes in Scala?
- Scala method override in Java
- Automate conversion of variables to Options in Scala
- unmarshalling json in spray-json
- Stop Hook Is Not Being Called When Play Application Is Shutting Down
- SbtOsgi AutoPlugin can't be loaded due to type mismatch error
- How val is initialised in two objects inheriting the same trait in scala?
- Play Framework Authentication in a single page app
- Specs2 sequential keyword