structured-streaming-Kafka2HBase项目介绍

Spark structured-streaming 消费kafka数据写入hbase
该项目修改基础配置就可以跑

数据格式

数据写入格式如下(中间分割符为\001)
dbName tableName tableRowkey tableData
tets test 1111 {"a1":"a1","a2":"a3"}

数据如下

"A"+ "\001"
+ "test2"+ "\001"
+ "1111"+ "\001"
+ "{\"a1\":\"a1\",\"a2\":\"a3\"}"

赞助