All Classes and Interfaces

Class	Description
AdminClientX	Provide methods for common operations when performing administrative actions on a Kafka cluster
App<T,C>	Kafka application that defines necessary configurations
AppConfiguration<T>	Configuration for setting up an app
BranchedKStreamX<K,V>	Extends the BranchedKStream interface by adding methods to simplify Serde configuration, error handling, and topic access
BranchedX<K,V>	Extends the Branched interface by adding methods to simplify Serde configuration, error handling, and topic access
CleanUpException	Exception thrown if running clean up was unsuccessful
CleanUpRunner	Cleans all resources associated with an application
CogroupedKStreamX<K,VOut>	Extends the CogroupedKStream interface by adding methods to simplify Serde configuration, error handling, and topic access
ConfigClient	This class offers helpers to interact with Kafka resource configs.
ConfiguredApp<E>	An application with a corresponding configuration
ConfiguredConsumerApp<T extends ConsumerApp>	A ConsumerApp with a corresponding ConsumerAppConfiguration
ConfiguredConsumerProducerApp<T extends ConsumerProducerApp>	A ConsumerProducerApp with a corresponding ConsumerProducerAppConfiguration
ConfiguredProducerApp<T extends ProducerApp>	A ProducerApp with a corresponding ProducerAppConfiguration
ConfiguredStreamsApp<T extends StreamsApp>	A StreamsApp with a corresponding StreamsAppConfiguration
ConsumedX<K,V>	Use Preconfigured to lazily configure Serde for Consumed using Configurator
ConsumerApp	Application that defines how to consume messages from Kafka and necessary configurations
ConsumerAppConfiguration	Configuration of a ConsumerApp
ConsumerApplicationException	Exception thrown if running conumser application was unsuccessful
ConsumerBuilder	Provides all runtime configurations when running a ConsumerApp
ConsumerCleanUpConfiguration	Provides configuration options for ConsumerCleanUpRunner
ConsumerCleanUpRunner	Clean up all topics specified by a ConsumerTopicConfig
ConsumerExecutionOptions	Options to run a Kafka Consumer app
ConsumerExecutionOptions.ConsumerExecutionOptionsBuilder
ConsumerGroupsClient	This class offers helpers to interact with Kafka consumer groups.
ConsumerGroupVerifier	Utility class to verify the state of a Kafka consumer group
ConsumerOptions	Shared CLI options to configure Kafka Consumer applications.
ConsumerProducerApp	Application that defines how to produce or consume messages to and from Kafka and necessary configurations
ConsumerProducerAppConfiguration	Configuration of a ConsumerProducerApp
ConsumerProducerBuilder	Provides all runtime configurations when running a ConsumerProducerApp
ConsumerProducerCleanUpRunner	Delete all output topics specified by a ConsumerProducerTopicConfig
ConsumerProducerExecutionOptions	Options to run a Kafka ConsumerProducer app
ConsumerProducerExecutionOptions.ConsumerProducerExecutionOptionsBuilder
ConsumerProducerRunnable	Produce or consume messages to or from Kafka
ConsumerProducerRunner	Runs a Kafka Consumer and Producer application
ConsumerProducerTopicConfig	Provides topic configuration for a ConsumerProducerApp
ConsumerProducerTopicConfig.ConsumerProducerTopicConfigBuilder
ConsumerRunnable	Consume messages from Kafka
ConsumerRunner	Runs a Kafka Consumer application
ConsumerTopicConfig	Provides topic configuration for a ConsumerApp
ConsumerTopicConfig.ConsumerTopicConfigBuilder
DefaultConsumerProducerRunnable<KOut,VOut>
DefaultConsumerRunnable<K,V>	Default implementation of ConsumerRunnable that manages the Kafka consumer poll loop and record processing lifecycle.
DeserializerConfig	Defines how to serialize the data in a Kafka producer
EnvironmentArgumentsParser	This class is primarily used to inject environment variables to the passed in command line arguments in KafkaPropertiesFactory.
EnvironmentKafkaConfigParser	Parse configuration properties of a Kafka app from environment variables
ErrorOptions	Shared CLI options to configure Kafka applications with an error topic.
ExecutableApp<R,C,O>	An application with a corresponding topic and Kafka configuration
ExecutableConsumerApp<T extends ConsumerApp>	A ConsumerApp with a corresponding ConsumerTopicConfig and Kafka configuration
ExecutableConsumerProducerApp<T extends ConsumerProducerApp>	A ConsumerProducerApp with a corresponding ConsumerProducerTopicConfig and Kafka configuration
ExecutableProducerApp<T extends ProducerApp>	A ProducerApp with a corresponding ProducerTopicConfig and Kafka configuration
ExecutableStreamsApp<T extends StreamsApp>	A StreamsApp with a corresponding Topology and StreamsConfig
GroupedX<K,V>	Use Preconfigured to lazily configure Serde for Grouped using Configurator
HasCleanHook<SELF>	Interface for performing actions when cleaning apps
HasTopicHooks<SELF>	Interface for performing actions on topics
HasTopicHooks.TopicHook	Hook for performing actions on topics
InputOptions	Shared CLI options to configure Kafka applications that consume input data.
JoinedX<K,V1,V2>	Use Preconfigured to lazily configure Serde for Joined using Configurator
KafkaAdminException	Exception thrown by if admin operations fail.
KafkaApplication<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 a CleanUpRunner and closes the associated ExecutableApp
KafkaApplication.RunnableApp<R extends Runner>	Provides access to a Runner and closes the associated ExecutableApp
KafkaConsumerApplication<T extends ConsumerApp>	The base class for creating Kafka Consumer applications.
KafkaConsumerProducerApplication<T extends ConsumerProducerApp>	The base class for creating Kafka ConsumerProducer applications.
KafkaProducerApplication<T extends ProducerApp>	The base class for creating Kafka Producer applications.
KafkaPropertiesFactory	Creates properties for a Kafka app.
KafkaPropertiesFactory.KafkaPropertiesFactoryBuilder
KafkaStreamsApplication<T extends StreamsApp>	The base class for creating Kafka Streams applications.
KafkaTestClient	Client that supports communication with Kafka clusters in test setups, including topic management, reading from and sending to topics.
KErrorStreamX<K,V,KR,VR>	KStreamX that contains successfully processed records and errors of a previous operation
KGroupedStreamX<K,V>	Extends the KGroupedStream interface by adding methods to simplify Serde configuration, error handling, and topic access
KGroupedTableX<K,V>	Extends the KGroupedTable interface by adding methods to simplify Serde configuration, error handling, and topic access
KStreamX<K,V>	Extends the KStream interface by adding methods to simplify Serde configuration, error handling, and topic access
KTableX<K,V>	Extends the KTable interface by adding methods to simplify Serde configuration, error handling, and topic access
LargeMessageAppUtils	Utility class that provides helpers for cleaning LargeMessageSerde artifacts
LargeMessageProducerApp	ProducerApp that automatically removes files associated with LargeMessageSerializer
LargeMessageStreamsApp	StreamsApp that automatically removes files associated with LargeMessageSerde
MaterializedX<K,V,S extends org.apache.kafka.streams.processor.StateStore>	Use Preconfigured to lazily configure Serde for Materialized using Configurator
OutputOptions	Shared CLI options to configure Kafka applications that produce output data.
ProducedX<K,V>	Use Preconfigured to lazily configure Serde for Produced using Configurator
ProducerApp	Application that defines how to produce messages to Kafka and necessary configurations
ProducerAppConfiguration	Configuration of a ProducerApp
ProducerBuilder	Provides all runtime configurations when running a ProducerApp
ProducerCleanUpConfiguration	Provides configuration options for ProducerCleanUpRunner
ProducerCleanUpRunner	Delete all output topics specified by a ProducerTopicConfig
ProducerExecutionOptions	Options to run a Kafka Producer app using ProducerRunner
ProducerExecutionOptions.ProducerExecutionOptionsBuilder
ProducerRunnable	Produce messages to Kafka
ProducerRunner	Runs a Kafka Producer application
ProducerTopicConfig	Provides topic configuration for a ProducerApp
ProducerTopicConfig.ProducerTopicConfigBuilder
ReaderBuilder<K,V>	Read data from a Kafka cluster
RepartitionedX<K,V>	Use Preconfigured to lazily configure Serde for Repartitioned using Configurator
Runner	Interface for running applications
RunningConsumer	A running KafkaConsumer instance along with its ConsumerConfig and ConsumerRunnable
RunningConsumer.RunningConsumerBuilder
RunningConsumerProducer	A running KafkaConsumer instance along with its ConsumerConfig and ConsumerRunnable
RunningConsumerProducer.RunningConsumerProducerBuilder
RunningStreams	A running KafkaStreams instance along with its StreamsConfig and Topology
RunningStreams.RunningStreamsBuilder
RuntimeConfiguration	Runtime configuration to connect to Kafka infrastructure, e.g., bootstrap servers and schema registry.
SchemaRegistryAppUtils	Utility class that provides helpers for removing schemas associated with topics
SenderBuilder<K,V>	Send data to a Kafka cluster
SenderBuilder.SimpleProducerRecord<K,V>	Represents a ProducerRecord without topic assignment
SerdeConfig	Defines how to (de-)serialize the data in a Kafka Streams app
SerializationConfig	Defines how to (de-)serialize the data in a Kafka client
SerializerConfig	Defines how to serialize the data in a Kafka producer
SerializerDeserializerConfig	Defines how to (de)serialize the data in a Kafka consumer or producer
SessionWindowedCogroupedKStreamX<K,VOut>	Extends the SessionWindowedCogroupedKStream interface by adding methods to simplify Serde configuration, error handling, and topic access
SessionWindowedKStreamX<K,V>	Extends the SessionWindowedKStream interface by adding methods to simplify Serde configuration, error handling, and topic access
SimpleKafkaConsumerApplication<T extends ConsumerApp>	KafkaConsumerApplication without any additional configuration options.
SimpleKafkaConsumerProducerApplication<T extends ConsumerProducerApp>	KafkaConsumerProducerApplication without any additional configuration options.
SimpleKafkaProducerApplication<T extends ProducerApp>	KafkaProducerApplication without any additional configuration options.
SimpleKafkaStreamsApplication<T extends StreamsApp>	KafkaStreamsApplication without any additional configuration options.
StoresX	Use Preconfigured to lazily configure Serde for Stores using Configurator
StreamJoinedX<K,V1,V2>	Use Preconfigured to lazily configure Serde for StreamJoined using Configurator
StreamsApp	Application that defines a Kafka Streams Topology and necessary configurations
StreamsAppConfiguration	Configuration of a StreamsApp
StreamsApplicationException	Exception thrown if running streams application was unsuccessful
StreamsBuilderX	Provides all runtime configurations and supports building a Topology of a StreamsApp
StreamsCleanUpConfiguration	Provides configuration options for StreamsCleanUpRunner
StreamsCleanUpRunner	Clean up the state and artifacts of your Kafka Streams app
StreamsConfigX	Class for simplified access to configs provided by StreamsConfig
StreamsContext	Provides context for the configured Kafka Streams application environment, i.e., topic configuration and StreamsConfig
StreamsExecutionOptions	Options to run a Kafka Streams app using StreamsRunner
StreamsExecutionOptions.StreamsExecutionOptionsBuilder
StreamsRunner	Runs a Kafka Streams application
StreamsTopicConfig	Provides topic configuration for a StreamsApp
StreamsTopicConfig.StreamsTopicConfigBuilder
StringListConverter	Converter for lists inside collection type parsed by PicoCLI.
TestApplicationRunner	Class that provides helpers for using running KafkaApplication in tests
TestApplicationTopologyFactory	Class that provides helpers for using Fluent Kafka Streams Tests with KafkaStreamsApplication
TestSchemaRegistry	Class that provides helpers for using schema registry in tests.
TestTopologyFactory	Class that provides helpers for using Fluent Kafka Streams Tests with ConfiguredStreamsApp
TimeWindowedCogroupedKStreamX<K,VOut>	Extends the TimeWindowedCogroupedKStream interface by adding methods to simplify Serde configuration, error handling, and topic access
TimeWindowedKStreamX<K,V>	Extends the TimeWindowedKStream interface by adding methods to simplify Serde configuration, error handling, and topic access
TopicsClient	This class offers helpers to interact with Kafka topics.
TopicSettings	Contains information about a topic, including number of partitions and replication factor.
TopicSettings.TopicSettingsBuilder