Package com.bakdata.kafka.consumerproducer
package com.bakdata.kafka.consumerproducer
-
ClassDescriptionConfiguredConsumerProducerApp<T extends ConsumerProducerApp>A
ConsumerProducerAppwith a correspondingConsumerProducerAppConfigurationApplication that defines how to produce or consume messages to and from Kafka and necessary configurationsConfiguration of aConsumerProducerAppProvides all runtime configurations when running aConsumerProducerAppDelete all output topics specified by aConsumerProducerTopicConfigOptions to run a Kafka ConsumerProducer appProduce or consume messages to or from KafkaRuns a Kafka Consumer and Producer applicationProvides topic configuration for aConsumerProducerAppDefaultConsumerProducerRunnable<KOut,VOut> ExecutableConsumerProducerApp<T extends ConsumerProducerApp>AConsumerProducerAppwith a correspondingConsumerProducerTopicConfigand Kafka configurationThe base class for creating Kafka ConsumerProducer applications.Defines how to (de)serialize the data in a Kafka consumer or producerKafkaConsumerProducerApplicationwithout any additional configuration options.