fume+kafka+storm+hbase的集成代碼

1.啓動hbase(前提啓動了zookeeper和hdfs) 查看進程: 進入hbaseshell終端: 查看hbase狀態: 查看錶列表: 查詢new_music_table數據: scan 'new_music_table' 2.啓動kafka: 3.編寫storm代碼: stormKafka.java: package stormHbase; import backtype.storm.C
相關文章
相關標籤/搜索