Prerequisites:
1. Java
2. Start zookeeper server
3. Start kafka and create a new topic
Creating
new topic
Test communication between Kafka and Spark
Run Kafka producer in a new screen
Run Spark’s KafkaWordCount in a new screen
Subscribe to:
Post Comments (Atom)
-
Getting the below error when installing oracle database 12c on linux machine Soft Limit: maximum stack size - This is a prerequisite con... -
After configuring SSL with Custom Identity and Trust Keystores and when we try to start the servers getting the below error ... -
1. Creating a directory in hdfs $ hdfs dfs -mkdir <paths> 2. List the directories in hdfs $ hdfs dfs -l...
No comments:
Post a Comment