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}")
             }
         }
     }