refac: make fields public

gapitio · Jan 15, 2025 · ef61361 · ef61361
1 parent a4a12aa
commit ef61361
Show file tree

Hide file tree

Showing 3 changed files with 17 additions and 29 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -39,8 +39,6 @@ version = "0.3.28"
 [dependencies.log]
 version = "0.4"
 
-[dependencies.rdkafka]
-version = "0.36.2"
 
 [dependencies.serde]
 version = "1.0"
@@ -58,3 +56,6 @@ features = ["full"]
 
 [dependencies.tokio-stream]
 version = "0.1"
+
+[dependencies]
+rdkafka = { git = "https://github.com/gapitio/gapit-rdkafka", rev = "c514b4880579b65d1a46908bd237a760158de056"} 
diff --git a/src/producer.rs b/src/producer.rs
@@ -124,7 +124,7 @@ impl KafkaProducer {
                 );
             }
             Err((error, owned_message)) => {
-                let topic = owned_message.topic;
+                let topic = owned_message.topic.clone();
                 let payload_size = owned_message.payload.unwrap_or_default().len();
                 let key = message.key;
                 let headers = owned_message.headers.unwrap_or_default();