启动

Kafka

cd ~/Public/installed/kafka/
bin/zookeeper-server-start.sh config/zookeeper.properties
bin/kafka-server-start.sh config/server.properties

emq

docker start emq20

进入控制台

docker exec -it emq20 /bin/sh

提交spark任务

spark-submit --packages org.apache.spark:spark-streaming-kafka-0-8_2.11:2.2.0 ./spark-streaming-recv.py

paho

sudo pip3 install paho-mqtt