From b03feb58f3e72871be6baf45fa345dee4a3e53a2 Mon Sep 17 00:00:00 2001
From: Thilo Behnke <thilo.behnke@gmx.net>
Date: Sun, 10 Jul 2022 15:15:19 +0200
Subject: [PATCH] added todo

---
 server/src/kafka.rs | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/server/src/kafka.rs b/server/src/kafka.rs
index 7d6f7c8..91a7947 100644
--- a/server/src/kafka.rs
+++ b/server/src/kafka.rs
@@ -149,7 +149,9 @@ impl EventReaderImpl for KafkaEventReaderImpl {
 impl KafkaEventReaderImpl {
     async fn consume(&mut self) -> Result<Vec<EventWrapper>, String> {
         debug!("kafka consumer called to consume messages for {:?} / {:?}", self.topic, self.partition);
-        // TODO: Only 1 message?
+        // TODO: This is a problem:
+        // - The peer inputs are intermittent to the host, because sometimes it will timeout without receiving the peer's inputs
+        // - The peer will receive the host's inputs intermittent in the same way.
         let next_res = tokio::time::timeout(Duration::from_millis(3), self.consumer.next()).await;
         if let Err(e) = next_res {
             info!("No record received in time after {}, timeout for {} / {}.", e, self.topic, self.partition);