diff options
| author | mjkwiatkowski <mati.rewa@gmail.com> | 2026-02-26 19:51:57 +0100 |
|---|---|---|
| committer | mjkwiatkowski <mati.rewa@gmail.com> | 2026-02-26 19:51:57 +0100 |
| commit | 82f8418f49b0564c5093c28be1ca522a628d0b4f (patch) | |
| tree | 140e6e4579229c8eefac398e58f386f270dff328 /opendc-common/src/main/kotlin/org/opendc/common/utils/Kafka.kt | |
| parent | 4f816318b6672d40f23b22ca44cc06b77cadf961 (diff) | |
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.kt | 5 |
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}") } } } |
