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
相关文章
相关标签/搜索