pcvolkmer/mv64e-kafka-to-rest-gateway
1
0
Fork 0
mirror of https://github.com/pcvolkmer/mv64e-kafka-to-rest-gateway synced 2025-09-13 09:12:52 +00:00
Code Activity

feat: log error if response could not be sent

Browse Source
This commit is contained in:
Paul-Christian Volkmer
2025-08-29 14:13:17 +02:00
parent f4176a906f
commit a3eef08510
1 changed files with 11 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/main.rs
View File

@@ -156,14 +156,13 @@ async fn main() -> Result<(), Box<dyn Error>> {
) )
.unwrap_or(json!({})), .unwrap_or(json!({})),
}; };
let response_payload = serde_json::to_string(&response_payload)?;
let payload = serde_json::to_string(&response_payload)?;
let response_record = FutureRecord::to(&CONFIG.response_topic) let response_record = FutureRecord::to(&CONFIG.response_topic)
.key(key) .key(key)
.payload(&payload); .payload(&response_payload);
let _ = if let Some(headers) = msg.headers() { match if let Some(headers) = msg.headers() {
producer producer
.send( .send(
response_record.headers(headers.detach()), response_record.headers(headers.detach()),
@@ -172,7 +171,14 @@ async fn main() -> Result<(), Box<dyn Error>> {
.await .await
} else { } else {
producer.send(response_record, Duration::from_secs(1)).await producer.send(response_record, Duration::from_secs(1)).await
}; } {
Ok(_) => {
info!("Response for '{request_id}' sent successfully");
}
Err((err, _)) => {
error!("Could not send response for '{request_id}': {err}");
}
}
if response.status_code == 200 || response.status_code == 201 || response.status_code == 400 || response.status_code == 422 { if response.status_code == 200 || response.status_code == 201 || response.status_code == 400 || response.status_code == 422 {
consumer consumer