Package com.bakdata.kafka
package com.bakdata.kafka
-
ClassDescriptionApp<T,
C> Kafka application that defines necessary configurationsConfiguration for setting up an appException thrown if running clean up was unsuccessfulCleans all resources associated with an applicationAn application with a corresponding configurationUtility class to verify the state of a Kafka consumer groupThis class is primarily used to inject environment variables to the passed in command line arguments inKafkaPropertiesFactory.Parse configuration properties of a Kafka app from environment variablesExecutableApp<R,C, O> An application with a corresponding topic and Kafka configurationHasCleanHook<SELF>Interface for performing actions when cleaning appsHasTopicHooks<SELF>Interface for performing actions on topicsHook for performing actions on topicsKafkaApplication<R extends Runner,CR extends CleanUpRunner, O, E extends ExecutableApp<R, CR, O>, CA extends ConfiguredApp<E>, T, A, AC> The base class for creating Kafka applications.KafkaApplication.CleanableApp<CR extends CleanUpRunner>Provides access to aCleanUpRunnerand closes the associatedExecutableAppKafkaApplication.RunnableApp<R extends Runner>Provides access to aRunnerand closes the associatedExecutableAppCreates properties for a Kafka app.Client that supports communication with Kafka clusters in test setups, including topic management, reading from and sending to topics.Utility class that provides helpers for cleaningLargeMessageSerdeartifactsReaderBuilder<K,V> Read data from a Kafka clusterInterface for running applicationsRuntime configuration to connect to Kafka infrastructure, e.g., bootstrap servers and schema registry.Utility class that provides helpers for removing schemas associated with topicsSenderBuilder<K,V> Send data to a Kafka clusterRepresents aProducerRecordwithout topic assignmentDefines how to (de-)serialize the data in a Kafka clientConverter for lists inside collection type parsed by PicoCLI.Class that provides helpers for using runningKafkaApplicationin testsClass that provides helpers for using schema registry in tests.