From 1eb4e5bd065f22f96ddc8052692520e202648cd0 Mon Sep 17 00:00:00 2001
From: Calvin Kirs <acm_master@163.com>
Date: Tue, 20 Jun 2023 11:44:02 +0800
Subject: [PATCH] [Fix](Routineload)routine load does not support lowercase
 data source names (#21005)

---
 .../routineload/RoutineLoadDataSourcePropertyFactory.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadDataSourcePropertyFactory.java b/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadDataSourcePropertyFactory.java
index bb371ba4ae..ec0d3bbb95 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadDataSourcePropertyFactory.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadDataSourcePropertyFactory.java
@@ -35,14 +35,14 @@ public class RoutineLoadDataSourcePropertyFactory {
 
     public static AbstractDataSourceProperties createDataSource(String type, Map<String, String> parameters,
                                                                 boolean multiLoad) {
-        if (type.equals(LoadDataSourceType.KAFKA.name())) {
+        if (type.equalsIgnoreCase(LoadDataSourceType.KAFKA.name())) {
             return new KafkaDataSourceProperties(parameters, multiLoad);
         }
         throw new IllegalArgumentException("Unknown routine load data source type: " + type);
     }
 
     public static AbstractDataSourceProperties createDataSource(String type, Map<String, String> parameters) {
-        if (type.equals(LoadDataSourceType.KAFKA.name())) {
+        if (type.equalsIgnoreCase(LoadDataSourceType.KAFKA.name())) {
             return new KafkaDataSourceProperties(parameters);
         }
         throw new IllegalArgumentException("Unknown routine load data source type: " + type);