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 applicationOptions to configure closing behavior of Kafka appsAn application with a corresponding configurationUtility class to verify the state of a Kafka consumer groupDefines how to serialize the data in a Kafka producerThis 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.