1.

Package which need to import in java/scala?

Answer»
  • IMPORT org.apache.kafka.clients.consumer.ConsumerRecord
  • import org.apache.kafka.common.serialization.StringDeserializer
  • import org.apache.spark.streaming.kafka010._
  • import org.apache.spark.streaming.kafka010.LocationStrategies.PreferConsistent
  • import org.apache.spark.streaming.kafka010.ConsumerStrategies.Subscribe


Discussion

No Comment Found

Related InterviewSolutions