From 4f816318b6672d40f23b22ca44cc06b77cadf961 Mon Sep 17 00:00:00 2001
From: mjkwiatkowski <mati.rewa@gmail.com>
Date: Mon, 23 Feb 2026 12:05:58 +0100
Subject: feat: added a working connection to Redis, and a scaffolding for the
 RESTful API

---
 .../src/main/kotlin/org/opendc/common/utils/Kafka.kt      | 15 ---------------
 1 file changed, 15 deletions(-)

(limited to 'opendc-common/src/main/kotlin/org/opendc/common/utils/Kafka.kt')

diff --git a/opendc-common/src/main/kotlin/org/opendc/common/utils/Kafka.kt b/opendc-common/src/main/kotlin/org/opendc/common/utils/Kafka.kt
index d7ccd385..1430898e 100644
--- a/opendc-common/src/main/kotlin/org/opendc/common/utils/Kafka.kt
+++ b/opendc-common/src/main/kotlin/org/opendc/common/utils/Kafka.kt
@@ -38,19 +38,4 @@ public class Kafka(private val topic: String) {
             }
         }
     }
-
-    // TODO: fix
-    public fun getReceive() : () -> Unit {
-        val consumer = KafkaConsumer<String, ProtobufMetrics.ProtoExport>(properties)
-        return fun() : Unit {
-            try {
-                consumer.subscribe(listOf(topic))
-                while (true) {
-                    consumer.poll(1.microseconds.toJavaDuration())
-                }
-            } catch (e: Exception) {
-                println("${e.message}")
-            }
-        }
-    }
 }
\ No newline at end of file
-- 
cgit v1.2.3