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
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
ConsumerGroupsClient	This class offers helpers to interact with Kafka consumer groups.
ConsumerGroupVerifier	Utility class to verify the state of a Kafka consumer group
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
ExecutableApp<R,C,O>	An application with a corresponding topic 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
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
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
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
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
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
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