From 82f8418f49b0564c5093c28be1ca522a628d0b4f Mon Sep 17 00:00:00 2001 From: mjkwiatkowski Date: Thu, 26 Feb 2026 19:51:57 +0100 Subject: feat: added notes from last meeting with my supervisor --- opendc-common/src/main/kotlin/org/opendc/common/utils/Kafka.kt | 5 +---- 1 file changed, 1 insertion(+), 4 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 1430898e..81eb6752 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 @@ -1,13 +1,10 @@ package org.opendc.common.utils import com.fasterxml.jackson.dataformat.toml.TomlMapper -import org.apache.kafka.clients.consumer.KafkaConsumer import org.apache.kafka.clients.producer.KafkaProducer import org.apache.kafka.clients.producer.ProducerRecord import org.opendc.common.ProtobufMetrics import java.util.* -import kotlin.time.Duration.Companion.microseconds -import kotlin.time.toJavaDuration /** * Represents the Kafka interface. * @constructor `topic` the Kafka topic @@ -34,7 +31,7 @@ public class Kafka(private val topic: String) { try { producer.send(ProducerRecord(this.topic, value)) } catch (e: Exception) { - println("${e.message}") + println("${e.message}") } } } -- cgit v1.2.3