topic id pattern default false

DTStack · Feb 22, 2020 · 45bed1f · 45bed1f
1 parent bf65420
commit 45bed1f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...base-source/src/main/java/com/dtstack/flink/sql/source/kafka/table/KafkaSourceParser.java b/...base-source/src/main/java/com/dtstack/flink/sql/source/kafka/table/KafkaSourceParser.java
@@ -51,7 +51,7 @@ public TableInfo getTableInfo(String tableName, String fieldsInfo, Map<String, O
         kafkaSourceTableInfo.setGroupId(MathUtil.getString(props.get(KafkaSourceTableInfo.GROUPID_KEY.toLowerCase())));
         kafkaSourceTableInfo.setTopic(MathUtil.getString(props.get(KafkaSourceTableInfo.TOPIC_KEY.toLowerCase())));
         kafkaSourceTableInfo.setOffsetReset(MathUtil.getString(props.get(KafkaSourceTableInfo.OFFSETRESET_KEY.toLowerCase())));
-        kafkaSourceTableInfo.setTopicIsPattern(MathUtil.getBoolean(props.get(KafkaSourceTableInfo.TOPICISPATTERN_KEY.toLowerCase())));
+        kafkaSourceTableInfo.setTopicIsPattern(MathUtil.getBoolean(props.get(KafkaSourceTableInfo.TOPICISPATTERN_KEY.toLowerCase()),false));
         kafkaSourceTableInfo.setTimeZone(MathUtil.getString(props.get(KafkaSourceTableInfo.TIME_ZONE_KEY.toLowerCase())));
         for (String key : props.keySet()) {
             if (!key.isEmpty() && key.startsWith("kafka.")) {