From 95d111d5e92ef2c58e413286e2da8e74da29e339 Mon Sep 17 00:00:00 2001
From: sunxiaojian <sunxiaojian926@163.com>
Date: Tue, 11 Apr 2023 18:14:42 +0800
Subject: [PATCH] fixed

---
 .../seatunnel/connectors/seatunnel/kafka/source/KafkaSource.java | 1 +
 1 file changed, 1 insertion(+)

diff --git a/seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSource.java b/seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSource.java
index 0c32ebb6263e..2d38d34c38ca 100644
--- a/seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSource.java
+++ b/seatunnel-connectors-v2/connector-kafka/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(