github/wasm-pong
1
0
Fork 0
mirror of https://github.com/thilo-behnke/wasm-pong.git synced 2026-07-11 02:29:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

bugfix: missing heartbeat topic for producer

Browse Source
This commit is contained in:
Thilo Behnke
2022-07-10 14:09:16 +02:00
parent 648f6f2563
commit d1ebc042d5
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
server/src/session_manager.rs
View File

@@ -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 {