zhongrj
2024-02-23 1af3f0036d8a0ede8f97ecb2075bee43109a4977
src/main/java/org/springblade/binlog/listener/MysqlBinLogListener.java
@@ -50,11 +50,10 @@
    */
   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);