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 aConsumerProducerAppProvides configuration options forConsumerProducerCleanUpRunnerRunner toConsumerProducerCleanUpRunner.clean()orConsumerProducerCleanUpRunner.reset()aConsumerProducerAppConsumerProducerCleanUpRunner.clean()deletes all output topics specified by aConsumerProducerTopicConfigand the consumer group specified in the constructor.Options 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.