actors/org.artofdev.actors.impl.net.kafka/KafkaSender

KafkaSender

class KafkaSender(jacksonMapper: ObjectMapper, val kafkaProducer: Producer<String, String>) : Closeable

Constructors

Link copied to clipboard
constructor(jacksonMapper: ObjectMapper, kafkaProducer: Producer<String, String>)

Properties

Link copied to clipboard
val kafkaProducer: Producer<String, String>

Functions

Link copied to clipboard
open override fun close()
Link copied to clipboard
fun sendMessage(topic: String, msgEnvelope: MessageEnvelope)
Generated by Dokka
© 2026 Copyright