producer: append error should also print stream name and shard id (#67)

hstreamdb · Sep 30, 2022 · 8690b47 · 8690b47
1 parent 610e060
commit 8690b47
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/src/hstreamdb/src/producer.rs b/src/hstreamdb/src/producer.rs
@@ -355,7 +355,7 @@ async fn flush(
             .map_err(|err| format!("producer connect error: url = {shard_url}, {err}"))?;
         let append_result = append(
             channel,
-            stream_name,
+            stream_name.clone(),
             shard_id,
             compression_type,
             buffer.to_vec(),
@@ -376,7 +376,9 @@ async fn flush(
                         })
                     }
                 }
-                Err(format!("producer append error: url = {shard_url}, {err}"))
+                Err(format!(
+                    "producer append error: url = {shard_url}, stream = {stream_name}, shard_id = {shard_id}, {err}"
+                ))
             }
             Ok(append_result) => {
                 log::debug!("append succeed: len = {}", append_result.len());