5.sparkstreaming去kafka中消費Mysql實時操做的數據

1前面Mysql開啓了Bin_log,canal實時的去監聽而後發送到kafka的example中,如今用Spark-streaming實時的去消費將這些信息打印出來 pom依賴:java <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka_2.11</artifact
相關文章
相關標籤/搜索