Package com.bakdata.kafka.producer
package com.bakdata.kafka.producer
-
ClassDescriptionConfiguredProducerApp<T extends ProducerApp>A
ProducerAppwith a correspondingProducerAppConfigurationExecutableProducerApp<T extends ProducerApp>AProducerAppwith a correspondingProducerTopicConfigand Kafka configurationKafkaProducerApplication<T extends ProducerApp>The base class for creating Kafka Producer applications.ProducerAppthat automatically removes files associated withLargeMessageSerializerApplication that defines how to produce messages to Kafka and necessary configurationsConfiguration of aProducerAppProvides all runtime configurations when running aProducerAppProvides configuration options forProducerCleanUpRunnerRunner toProducerCleanUpRunner.clean()aProducerAppProducerCleanUpRunner.clean()deletes all output topics specified by aProducerTopicConfigand runs hooks registered in aProducerCleanUpConfiguration.Options to run a Kafka Producer app usingProducerRunnerProduce messages to KafkaRuns a Kafka Producer applicationProvides topic configuration for aProducerAppDefines how to serialize the data in a Kafka producerSimpleKafkaProducerApplication<T extends ProducerApp>KafkaProducerApplicationwithout any additional configuration options.