summaryrefslogtreecommitdiff
path: root/opendc-common/src/main/kotlin/org/opendc/common/utils/Kafka.kt
diff options
context:
space:
mode:
authormjkwiatkowski <mati.rewa@gmail.com>2026-02-26 19:51:57 +0100
committermjkwiatkowski <mati.rewa@gmail.com>2026-02-26 19:51:57 +0100
commit82f8418f49b0564c5093c28be1ca522a628d0b4f (patch)
tree140e6e4579229c8eefac398e58f386f270dff328 /opendc-common/src/main/kotlin/org/opendc/common/utils/Kafka.kt
parent4f816318b6672d40f23b22ca44cc06b77cadf961 (diff)
feat: added notes from last meeting with my supervisorHEADmaster
Diffstat (limited to 'opendc-common/src/main/kotlin/org/opendc/common/utils/Kafka.kt')
-rw-r--r--opendc-common/src/main/kotlin/org/opendc/common/utils/Kafka.kt5
1 files changed, 1 insertions, 4 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 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}")
}
}
}