Package com.bakdata.kafka.consumer
package com.bakdata.kafka.consumer
-
ClassDescriptionConfiguredConsumerApp<T extends ConsumerApp>A
ConsumerAppwith a correspondingConsumerAppConfigurationApplication that defines how to consume messages from Kafka and necessary configurationsConfiguration of aConsumerAppException thrown if running conumser application was unsuccessfulProvides all runtime configurations when running aConsumerAppProvides configuration options forConsumerCleanUpRunnerClean up all topics specified by aConsumerTopicConfigOptions to run a Kafka Consumer appConsume messages from KafkaRuns a Kafka Consumer applicationProvides topic configuration for aConsumerAppDefault implementation ofConsumerRunnablethat manages the Kafka consumer poll loop and record processing lifecycle.ExecutableConsumerApp<T extends ConsumerApp>AConsumerAppwith a correspondingConsumerTopicConfigand Kafka configurationKafkaConsumerApplication<T extends ConsumerApp>The base class for creating Kafka Consumer applications.SimpleKafkaConsumerApplication<T extends ConsumerApp>KafkaConsumerApplicationwithout any additional configuration options.