已解决 使用google的protobuf解析（遇到类似问题参考: Java解析drainer发送到kafka中的binlog异常 ）：
20-08-2019 12:49:25 CST testStream INFO - **********************
20-08-2019 12:49:25 CST testStream INFO - type: DML
20-08-2019 12:49:25 CST testStream INFO - commit_ts: 410588031694143489
20-08-2019 12:49:25 CST testStream INFO - dml_data {
20-08-2019 12:49:25 CST testStream INFO - tables {
20-08-2019 12:49:25 CST testStream INFO - schema_name: "hydee"
20-08-2019 12:49:25 CST testStream INFO - table_name: "binlog_test"
20-08-2019 12:49:25 CST testStream INFO - column_info {
20-08-2019 12:49:25 CST testStream INFO - name: "id"
20-08-2019 12:49:25 CST testStream INFO - mysql_type: "int"
20-08-2019 12:49:25 CST testStream INFO - is_primary_key: false
20-08-2019 12:49:25 CST testStream INFO - }
20-08-2019 12:49:25 CST testStream INFO - column_info {
20-08-2019 12:49:25 CST testStream INFO - name: "name"
20-08-2019 12:49:25 CST testStream INFO - mysql_type: "varchar"
20-08-2019 12:49:25 CST testStream INFO - is_primary_key: false
20-08-2019 12:49:25 CST testStream INFO - }
20-08-2019 12:49:25 CST testStream INFO - mutations {
20-08-2019 12:49:25 CST testStream INFO - type: Insert
20-08-2019 12:49:25 CST testStream INFO - row {
20-08-2019 12:49:25 CST testStream INFO - columns {
20-08-2019 12:49:25 CST testStream INFO - int64_value: 7
20-08-2019 12:49:25 CST testStream INFO - }
20-08-2019 12:49:25 CST testStream INFO - columns {
20-08-2019 12:49:25 CST testStream INFO - string_value: "g"
20-08-2019 12:49:25 CST testStream INFO - }
20-08-2019 12:49:25 CST testStream INFO - }
20-08-2019 12:49:25 CST testStream INFO - }
20-08-2019 12:49:25 CST testStream INFO - }
20-08-2019 12:49:25 CST testStream INFO - }
20-08-2019 12:49:25 CST testStream INFO -
20-08-2019 12:49:25 CST testStream INFO - ***************************