Google News
logo
Kafka - Interview Questions
Package which need to import in java/scala?
* 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
Advertisement