This article explains how to write Kafka Producer and Consumer example in Scala. Producer sends messages to Kafka topics in the form of records, a record is a key-value pair along with topic name and consumer receives a messages from a topic.
If you are getting below exception while setting up Cassandra cluster, please follow below steps…
YARN / Map Reduce 2 (Yet Another Resource Negotiator) Resource Manager The ResourceManager is…
In Spark or PySpark SparkSession object is created programmatically using SparkSession.builder() and if you are…
Are you getting WARNING: "HADOOP_PREFIX has been replaced by HADOOP_HOME. Using value of HADOOP_PREFIX. ? for every command you issue on a cluster, follow below step to resolve it.
When your datanodes are not starting due to java.io.IOException: Incompatible clusterIDs error, means you have formatted namenode with out deleting files from datanode.
Below are the steps of Apache Hadoop Installation on a Linux Ubuntu server, if you…
Let's see how to create Spark RDD using sparkContext.parallelize() method and using Spark shell and…