添加kafka processor，配置如下

?

kakfa數據格式為JSON：

{"events_tag":"103913","query_word":"華大癌變 虎嗅","time":"2018-08-09 13:01:11"}

?

添加putHbaseJSON，json格式添加數據

?

?

?

?

指定rowkey，只能填寫一個

配置HbaseClient，可以使用配置文件，也可直接填寫配置

總結

以上是生活随笔為你收集整理的Nifi 之 kafka消费存入hbase的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。