fix

Signed-off-by: Richard Chien <[email protected]>
risingwavelabs · Apr 24, 2024 · 430db2c · 430db2c
1 parent 491b05a
commit 430db2c
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/src/connector/src/source/kafka/enumerator/client.rs b/src/connector/src/source/kafka/enumerator/client.rs
@@ -319,7 +319,7 @@ impl KafkaSplitEnumerator {
                 Offset::Offset(offset) => {
                     result.insert(elem.partition(), Some(offset));
                 }
-                Offset::End => {
+                _ => {
                     let (_, high_watermark) = self
                         .client
                         .fetch_watermarks(
@@ -330,7 +330,6 @@ impl KafkaSplitEnumerator {
                         .await?;
                     result.insert(elem.partition(), Some(high_watermark));
                 }
-                _ => unreachable!(),
             }
         }