将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
暂无答案!
目前还没有任何答案,快来回答吧!