Package com.bakdata.kafka.streams
package com.bakdata.kafka.streams
-
ClassDescriptionConfiguredStreamsApp<T extends StreamsApp>A
StreamsAppwith a correspondingStreamsAppConfigurationExecutableStreamsApp<T extends StreamsApp>KafkaStreamsApplication<T extends StreamsApp>The base class for creating Kafka Streams applications.StreamsAppthat automatically removes files associated withLargeMessageSerdeA runningKafkaStreamsinstance along with itsStreamsConfigandTopologyDefines how to (de-)serialize the data in a Kafka Streams appSimpleKafkaStreamsApplication<T extends StreamsApp>KafkaStreamsApplicationwithout any additional configuration options.Application that defines a Kafka StreamsTopologyand necessary configurationsConfiguration of aStreamsAppException thrown if running streams application was unsuccessfulProvides configuration options forStreamsCleanUpRunnerClean up the state and artifacts of your Kafka Streams appClass for simplified access to configs provided byStreamsConfigOptions to run a Kafka Streams app usingStreamsRunnerRuns a Kafka Streams applicationProvides topic configuration for aStreamsAppClass that provides helpers for using Fluent Kafka Streams Tests withKafkaStreamsApplicationClass that provides helpers for using Fluent Kafka Streams Tests withConfiguredStreamsApp