Package com.bakdata.kafka.streams.kstream

package com.bakdata.kafka.streams.kstream
  • Class
    Description
    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
    CogroupedKStreamX<K,VOut>
    Extends the CogroupedKStream interface by adding methods to simplify Serde configuration, error handling, and topic access
    ConsumedX<K,V>
    Use Preconfigured to lazily configure Serde for Consumed using Configurator
    GroupedX<K,V>
    Use Preconfigured to lazily configure Serde for Grouped using Configurator
    JoinedX<K,V1,V2>
    Use Preconfigured to lazily configure Serde for Joined using Configurator
    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
    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
    RepartitionedX<K,V>
    Use Preconfigured to lazily configure Serde for Repartitioned using Configurator
    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
    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
    StreamsBuilderX
    Provides all runtime configurations and supports building a Topology of a StreamsApp
    StreamsContext
    Provides context for the configured Kafka Streams application environment, i.e., topic configuration and StreamsConfig
    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