feat: added a working connection to Redis, and a scaffolding for the RESTful APIHEADmaster

1 files changed, 0 insertions, 15 deletions

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