Package com.bakdata.kafka.producer
package com.bakdata.kafka.producer
-
ClassDescriptionConfiguredProducerApp<T extends ProducerApp>A
ProducerApp
with a correspondingProducerAppConfiguration
ExecutableProducerApp<T extends ProducerApp>AProducerApp
with a correspondingProducerTopicConfig
and Kafka configurationKafkaProducerApplication<T extends ProducerApp>The base class for creating Kafka Producer applications.ProducerApp
that automatically removes files associated withLargeMessageSerializer
Application that defines how to produce messages to Kafka and necessary configurationsConfiguration of aProducerApp
Provides all runtime configurations when running aProducerApp
Provides configuration options forProducerCleanUpRunner
Delete all output topics specified by aProducerTopicConfig
Options to run a Kafka Producer app usingProducerRunner
Produce messages to KafkaRuns a Kafka Producer applicationProvides topic configuration for aProducerApp
Defines how to serialize the data in a Kafka producerSimpleKafkaProducerApplication<T extends ProducerApp>KafkaProducerApplication
without any additional configuration options.