txpipe
diff --git a/‎Cargo.lock
+39-86 b/‎Cargo.lock
+39-86
diff --git a/‎Cargo.toml
+1-1 b/‎Cargo.toml
+1-1
@@ -38,7 +38,7 @@ file-rotate = { version = "0.7.1", optional = true }
 reqwest = { version = "0.11", optional = true, features = ["blocking", "json"] }
 
 # feature: kafkasink
-kafka = { version = "0.8.0", optional = true }
+kafka = { version = "0.10.0", optional = true }
 
 # feature: elasticsink
 elasticsearch = { version = "7.14.0-alpha.1", optional = true }