fixed

apache · Apr 11, 2023 · 95d111d · 95d111d
1 parent 64326c6
commit 95d111d
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...fka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSource.java b/...fka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSource.java
@@ -266,6 +266,7 @@ private void setDeserialization(Config config) {
                             CanalJsonDeserializationSchema.builder(typeInfo)
                                     .setIgnoreParseErrors(true)
                                     .build();
+                    break;
                 case COMPATIBLE_KAFKA_CONNECT_JSON:
                     deserializationSchema =
                             new CompatibleKafkaConnectDeserializationSchema(