修复已知问题

core/src/main/java/com/tbyf/cdcengine2/core/ChangeListener.java

-package com.tbyf.cdcengine2.core;
-
-public interface ChangeListener {
-
-    default boolean supportsSchema(String schema) {
-        return true;
-    }
-
-    default boolean supportsTable(String table) {
-        return true;
-    }
-
-    default boolean supports(String schema, String table) {
-        return supportsSchema(schema) && supportsTable(table);
-    }
-
-    void onChange(ChangedRecord record);
-}

core/src/main/java/com/tbyf/cdcengine2/core/DefaultChangeEventAdapter.java

@@ -69,7 +69,7 @@ public class DefaultChangeEventAdapter implements ChangeEventAdapter {
                 if (field.schema().type() == Schema.Type.STRUCT) {
                     Struct structValue = (Struct) value;
                     // 处理小数类型
-                    if (field.schema().name().equals(VariableScaleDecimal.class.getName())) {
+                    if (VariableScaleDecimal.class.getName().equals(field.schema().name())) {
                         value = new BigDecimal(new BigInteger(structValue.getBytes(VariableScaleDecimal.VALUE_FIELD)),
                                 structValue.getInt32(VariableScaleDecimal.SCALE_FIELD));
                     }
@@ -77,7 +77,7 @@ public class DefaultChangeEventAdapter implements ChangeEventAdapter {
                 if (field.schema().type() == Schema.Type.INT64) {
                     Long longValue = (Long) value;
                     // 处理时间类型
-                    if (field.schema().name().equals(Timestamp.class.getName())) {
+                    if (Timestamp.class.getName().equals(field.schema().name())) {
                         value = LocalDateTime.ofInstant(Instant.ofEpochMilli(longValue), ZoneOffset.UTC);
                     }
                 }