chore: change kafka producer due to new event publisher type

Author: andrea-acampora

src/main/kotlin/infrastructure/digitaltwins/parser/DTEventParser.kt

@@ -14,10 +14,9 @@ import com.fasterxml.jackson.module.kotlin.readValue
 import entities.events.EmptyEvent
 import entities.events.Event
 import infrastructure.digitaltwins.events.RelationshipEvents.RelationshipEvent
-import infrastructure.digitaltwins.events.TwinProperties.DTEventTypes.UPDATE
-import infrastructure.digitaltwins.events.TwinProperties.DTEventTypes.RELATIONSHIP_DELETE
 import infrastructure.digitaltwins.events.TwinProperties.DTEventTypes.RELATIONSHIP_CREATE
-
+import infrastructure.digitaltwins.events.TwinProperties.DTEventTypes.RELATIONSHIP_DELETE
+import infrastructure.digitaltwins.events.TwinProperties.DTEventTypes.UPDATE
 import infrastructure.digitaltwins.events.UpdateEvents.UpdateTwinEvent
 
 /**

src/main/kotlin/infrastructure/kafka/KafkaPublisher.kt

@@ -17,15 +17,15 @@ import org.apache.kafka.clients.producer.ProducerRecord
 /**
  * The publisher of events to a Kafka Event Broker.
  */
-class KafkaPublisher : EventPublisher<Event<Any>> {
+class KafkaPublisher : EventPublisher<Event<*>> {
 
     init {
         listOf(System.getenv("BOOTSTRAP_SERVER_URL"), System.getenv("SCHEMA_REGISTRY_URL")).forEach {
             requireNotNull(it) {
                 println(
                     """
                     Invalid environment variable!
-                    Check the documentation here: 
+                    Check the documentation here:
                     https://github.com/SmartOperatingBlock/bootstrap")"""
                         .trimIndent()
                 )
@@ -46,9 +46,9 @@ class KafkaPublisher : EventPublisher<Event<Any>> {
         "TRACKING_EVENT" to "tracking-events"
     )
 
-    private val producer: KafkaProducer<String, Event<Any>> = KafkaProducer(producerProps)
+    private val producer: KafkaProducer<String, Event<*>> = KafkaProducer(producerProps)
 
-    override fun publishEvent(event: Event<Any>) {
+    override fun publishEvent(event: Event<*>) {
         val record = ProducerRecord(eventToTopic[event.key], event.key, event)
         producer.send(record)
     }