/Kafka2SparkDns

Primary LanguageScala

spark streaming 测试代码

Test.scala通过filebeat采集到kafka，在通过spark streaming提取json数据，放在hbase

其他都是logstash采集