hbase中的数据类型转换

oxcyiej7  于 2021-06-06  发布在  Kafka
关注(0)|答案(0)|浏览(224)

将hbase streamreactor kafka连接器用于此配置的

name=person-hbase 
connector.class=com.datamountaineer.streamreactor.connect.hbase.HbaseSinkConnector 
tasks.max=1 
topics=hbase-topic
connect.hbase.column.family=d
connect.hbase.kcql=INSERT INTO person SELECT * FROM hbase-topic PK firstName, lastName

为什么Kafka向hbase发送的值用这种方式表示? value=@\xB56\x00\x00\x00\x00\x00 如何把它改成正常的可读方式?

hbase(main):004:0* scan 'person'
ROW                                                  COLUMN+CELL
 Anna\x0AJones                                       column=d:age, timestamp=1463056888641, value=\x00\x00\x00\x1C
 Anna\x0AJones                                       column=d:firstName, timestamp=1463056888641, value=Anna
 Anna\x0AJones                                       column=d:income, timestamp=1463056888641, value=@\xB56\x00\x00\x00\x00\x00
 Anna\x0AJones                                       column=d:lastName, timestamp=1463056888641, value=Jones
 John\x0ASmith                                       column=d:age, timestamp=1463056693877, value=\x00\x00\x00\x1E
 John\x0ASmith                                       column=d:firstName, timestamp=1463056693877, value=John
 John\x0ASmith                                       column=d:income, timestamp=1463056693877, value=@\xB2\xDE\x00\x00\x00\x00\x00
 John\x0ASmith                                       column=d:lastName, timestamp=1463056693877, value=Smith
2 row(s) in 0.0260 seconds

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题