From 726e18ba460d2fbdb079a6f583e6826eeccd94ff Mon Sep 17 00:00:00 2001
From: Thilo Behnke <thilo.behnke@gmx.net>
Date: Thu, 23 Jun 2022 21:52:18 +0200
Subject: [PATCH] more logging

---
 server/src/http.rs  |  2 +-
 server/src/kafka.rs | 11 ++++++++---
 2 files changed, 9 insertions(+), 4 deletions(-)

diff --git a/server/src/http.rs b/server/src/http.rs
index c80bdfc..fce482f 100644
--- a/server/src/http.rs
+++ b/server/src/http.rs
@@ -180,7 +180,7 @@ async fn handle_http_request(
 
 async fn shutdown_signal() {
     // Wait for the CTRL+C signal
-    let shutdown_received = tokio::signal::ctrl_c()
+    tokio::signal::ctrl_c()
         .await
         .expect("failed to install CTRL+C signal handler");
     info!("received shutdown signal, shutting down now...");
diff --git a/server/src/kafka.rs b/server/src/kafka.rs
index 3b4e7f3..067a505 100644
--- a/server/src/kafka.rs
+++ b/server/src/kafka.rs
@@ -5,6 +5,7 @@ use hyper::{Body, Client, Method, Request, Uri};
 use kafka::client::ProduceMessage;
 use kafka::consumer::{Consumer, FetchOffset, GroupOffsetStorage, MessageSet};
 use kafka::producer::{Partitioner, Producer, Record, RequiredAcks, Topics};
+use log::{error, info};
 use serde::Deserialize;
 
 use pong::event::event::{Event, EventReaderImpl, EventWriterImpl};
@@ -33,12 +34,16 @@ pub struct KafkaDefaultEventWriterImpl {
 
 impl KafkaDefaultEventWriterImpl {
     pub fn new(host: &str) -> KafkaDefaultEventWriterImpl {
-        println!("Connecting default producer to kafka host: {}", host);
+        info!("connecting default producer to kafka host: {}", host);
         let producer = Producer::from_hosts(vec![host.to_owned()])
             .with_ack_timeout(Duration::from_secs(1))
             .with_required_acks(RequiredAcks::One)
-            .create()
-            .unwrap();
+            .create();
+        if let Err(e) = producer {
+            error!("failed to connect producer to kafka host {}: {:?}", host, e);
+            panic!("kafka connection failed, no recovery possible.")
+        }
+        let producer = producer.unwrap();
         KafkaDefaultEventWriterImpl { producer }
     }
 }