From d1ebc042d5ea93480250862e35209def7bd5d8ab Mon Sep 17 00:00:00 2001
From: Thilo Behnke <thilo.behnke@gmx.net>
Date: Sun, 10 Jul 2022 14:09:16 +0200
Subject: [PATCH] bugfix: missing heartbeat topic for producer

---
 server/src/session_manager.rs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/server/src/session_manager.rs b/server/src/session_manager.rs
index 068dcd5..9ce8321 100644
--- a/server/src/session_manager.rs
+++ b/server/src/session_manager.rs
@@ -235,7 +235,7 @@ impl SessionManager {
             return Err(format!("Unable to find session with hash {}", session_id));
         }
         let session = session.unwrap();
-        let writer = KafkaSessionEventWriterImpl::new(&self.kafka_host, vec!["move", "status", "input", "session"], &i32::from(session.id)).await;
+        let writer = KafkaSessionEventWriterImpl::new(&self.kafka_host, vec!["move", "status", "input", "session", "heart_beat"], &i32::from(session.id)).await;
         let event_writer =
             EventWriter::new(Box::new(writer));
         Ok(SessionWriter {