package kafka
Type Members
- case class KafkaConnection(config: KafkaConnectionConfig) extends DQConnection with DQStreamingConnection with Product with Serializable
-
case class
KafkaOutput(messages: Seq[(String, String)], topic: String, options: Seq[String] = Seq.empty[String]) extends Product with Serializable
Defines data to be sent to Kafka topic
Defines data to be sent to Kafka topic
- messages
Sequence of messages to sent. Message is a tuple: key -> value
- topic
Topic to send messages to.
- options
Additional Kafka options for sending messages.
-
class
ProducerCallback extends Callback
Kafka producer callback that collects error messages if any.