使用kafak获取tidb同步的binlog,格式如下:
Time: 1566201952000 ms
19-08-2019 16:05:52 CST test INFO - -------------------------------------------
19-08-2019 16:05:52 CST test INFO - �������"|
19-08-2019 16:05:52 CST test INFO - hydeebinlog_testfCREATE TABLE hydee.binlog_test (
19-08-2019 16:05:52 CST test INFO - id INT,
19-08-2019 16:05:52 CST test INFO - name VARCHAR(20)
19-08-2019 16:05:52 CST test INFO - ) ENGINE = InnoDB ROW_FORMAT = DEFAULT23333
19-08-2019 16:05:52 CST test INFO - �����¨�E
19-08-2019 16:05:52 CST test INFO - C
19-08-2019 16:05:52 CST test INFO - hydeebinlog_test
19-08-2019 16:05:52 CST test INFO - idint
19-08-2019 16:05:52 CST test INFO - nameavarchar"
19-08-2019 16:05:52 CST test INFO -
19-08-2019 16:05:52 CST test INFO -
19-08-2019 16:05:52 CST test INFO - 2a23333
19-08-2019 16:05:52 CST test INFO - �����E
19-08-2019 16:05:52 CST test INFO - C
19-08-2019 16:05:52 CST test INFO - hydeebinlog_test
19-08-2019 16:05:52 CST test INFO - idint
19-08-2019 16:05:52 CST test INFO - nameavarchar"
19-08-2019 16:05:52 CST test INFO -
19-08-2019 16:05:52 CST test INFO -
19-08-2019 16:05:52 CST test INFO - 2b23333
19-08-2019 16:05:52 CST test INFO - �����Ԩ�T
19-08-2019 16:05:52 CST test INFO - R
19-08-2019 16:05:52 CST test INFO - hydeebinlog_test
19-08-2019 16:05:52 CST test INFO - idint
19-08-2019 16:05:52 CST test INFO - nameavarchar"
19-08-2019 16:05:52 CST test INFO -
19-08-2019 16:05:52 CST test INFO -
19-08-2019 16:05:52 CST test INFO - 2a"
19-08-2019 16:05:52 CST test INFO -
19-08-2019 16:05:52 CST test INFO -
19-08-2019 16:05:52 CST test INFO - 2b23333
19-08-2019 16:05:52 CST test INFO - �����Ԩ�E
19-08-2019 16:05:52 CST test INFO - C
19-08-2019 16:05:52 CST test INFO - hydeebinlog_test
19-08-2019 16:05:52 CST test INFO - idint
19-08-2019 16:05:52 CST test INFO - nameavarchar"
19-08-2019 16:05:52 CST test INFO -
19-08-2019 16:05:52 CST test INFO -
19-08-2019 16:05:52 CST test INFO - 2a23333
19-08-2019 16:05:52 CST test INFO - �����ը�E
19-08-2019 16:05:52 CST test INFO - C
19-08-2019 16:05:52 CST test INFO - hydeebinlog_test
19-08-2019 16:05:52 CST test INFO - idint
19-08-2019 16:05:52 CST test INFO - nameavarchar"
19-08-2019 16:05:52 CST test INFO -
19-08-2019 16:05:52 CST test INFO -
19-08-2019 16:05:52 CST test INFO - 2a23333
19-08-2019 16:05:52 CST test INFO - ���܍ը�E
19-08-2019 16:05:52 CST test INFO - C
19-08-2019 16:05:52 CST test INFO - hydeebinlog_test
19-08-2019 16:05:52 CST test INFO - idint
19-08-2019 16:05:52 CST test INFO - nameavarchar"
19-08-2019 16:05:52 CST test INFO -
19-08-2019 16:05:52 CST test INFO -
19-08-2019 16:05:52 CST test INFO - 2a23333
19-08-2019 16:05:52 CST test INFO - �����ݨ�E
19-08-2019 16:05:52 CST test INFO - C
19-08-2019 16:05:52 CST test INFO - hydeebinlog_test
19-08-2019 16:05:52 CST test INFO - idint
19-08-2019 16:05:52 CST test INFO - nameavarchar"
19-08-2019 16:05:52 CST test INFO -
19-08-2019 16:05:52 CST test INFO -
19-08-2019 16:05:52 CST test INFO - 2a23333
19-08-2019 16:05:52 CST test INFO - �����ݨ�E
19-08-2019 16:05:52 CST test INFO - C
19-08-2019 16:05:52 CST test INFO - hydeebinlog_test
19-08-2019 16:05:52 CST test INFO - idint
19-08-2019 16:05:52 CST test INFO - nameavarchar"
19-08-2019 16:05:52 CST test INFO -
19-08-2019 16:05:52 CST test INFO -
19-08-2019 16:05:52 CST test INFO - 2a23333
19-08-2019 16:05:52 CST test INFO - �������E
19-08-2019 16:05:52 CST test INFO - C
19-08-2019 16:05:52 CST test INFO - hydeebinlog_test
19-08-2019 16:05:52 CST test INFO - idint
19-08-2019 16:05:52 CST test INFO - nameavarchar"
19-08-2019 16:05:52 CST test INFO -
19-08-2019 16:05:52 CST test INFO -
19-08-2019 16:05:52 CST test INFO - 2b23333
19-08-2019 16:05:52 CST test INFO - ...
19-08-2019 16:05:52 CST test INFO -
19-08-2019 16:05:52 CST test INFO - 2019-08-19 16:05:52 INFO JobScheduler:54 - Finished job streaming job 1566201952000 ms.0 from job set of time 1566201952000 ms
19-08-2019 16:05:52 CST test INFO - 2019-08-19 16:05:52 INFO JobScheduler:54 - Total delay: 0.969 s for time 1566201952000 ms (execution: 0.893 s)
19-08-2019 16:05:52 CST test INFO - 2019-08-19 16:05:52 INFO ReceivedBlockTracker:54 - Deleting batches:
怎么把他解析成表里的数据? 看了一下官网的例子,go语言没看懂,有没有简单点的,java版的