core/karya.core.entities/Action/KafkaProducerRequest

KafkaProducerRequest

@Serializable

data class KafkaProducerRequest(val key: String? = null, val topic: String, val message: String) : Action

Data class representing a Kafka request action.

Constructors

KafkaProducerRequest

constructor(key: String? = null, topic: String, message: String)

Properties

val key: String? = null

The key to be used to specify the partition to which the message will be sent.

val message: String

The message to be sent to the Kafka topic.

val topic: String

The Kafka topic where the message will be sent.