| | |
| | | */ |
| | | public MysqlBinLogListener(DataSourceConfig conf) { |
| | | BinaryLogClient client = new BinaryLogClient(conf.getHost(), conf.getPort(), conf.getUsername(), conf.getPassword()); |
| | | // 序列化 EventDeserializer.CompatibilityMode.CHAR_AND_BINARY_AS_BYTE_ARRAY 该设置会将varchar 转为 byte[] |
| | | EventDeserializer eventDeserializer = new EventDeserializer(); |
| | | //eventDeserializer.setCompatibilityMode(//序列化 |
| | | // EventDeserializer.CompatibilityMode.DATE_AND_TIME_AS_LONG, |
| | | // EventDeserializer.CompatibilityMode.CHAR_AND_BINARY_AS_BYTE_ARRAY |
| | | //); |
| | | eventDeserializer.setCompatibilityMode(EventDeserializer.CompatibilityMode.DATE_AND_TIME_AS_LONG |
| | | ); |
| | | client.setEventDeserializer(eventDeserializer); |
| | | this.parseClient = client; |
| | | this.queue = new ArrayBlockingQueue<>(1024); |