fix(connector): kinesis impl is mismatched to pulsar (#2390)

risingwavelabs · May 9, 2022 · 7b94dad · 7b94dad
1 parent cffc6ac
commit 7b94dad
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/connector/src/base.rs b/src/connector/src/base.rs
@@ -252,7 +252,7 @@ impl SplitImpl {
         match self {
             SplitImpl::Kafka(_) => KAFKA_SPLIT_TYPE,
             SplitImpl::Pulsar(_) => PULSAR_SPLIT_TYPE,
-            SplitImpl::Kinesis(_) => PULSAR_SPLIT_TYPE,
+            SplitImpl::Kinesis(_) => KINESIS_SPLIT_TYPE,
             SplitImpl::Nexmark(_) => NEXMARK_SPLIT_TYPE,
         }
         .to_string()