fix rebase

MaterializeInc · Mar 14, 2022 · a2973db · a2973db
1 parent 275bad5
commit a2973db
Showing 1 changed file with 0 additions and 8 deletions.
diff --git a/src/dataflow/src/source/kafka.rs b/src/dataflow/src/source/kafka.rs
@@ -76,14 +76,6 @@ pub struct KafkaSourceReader {
     partition_metrics: KafkaPartitionMetrics,
 }
 
-struct UnparkOnDrop<T>(JoinHandle<T>);
-
-impl<T> Drop for UnparkOnDrop<T> {
-    fn drop(&mut self) {
-        self.0.thread().unpark();
-    }
-}
-
 impl SourceReader for KafkaSourceReader {
     type Key = Option<Vec<u8>>;
     type Value = Option<Vec<u8>>;