Package com.bakdata.kafka.streams.kstream

Interface KGroupedStreamX<K,V>

Type Parameters:
K - type of keys
V - type of values
All Superinterfaces:
org.apache.kafka.streams.kstream.KGroupedStream<K,V>
public interface KGroupedStreamX<K,V> extends org.apache.kafka.streams.kstream.KGroupedStream<K,V>
Extends the KGroupedStream interface by adding methods to simplify Serde configuration, error handling, and topic access

  • Method Summary

    Modifier and Type
    Method
    Description
    <VR> KTableX<K,VR>
    aggregate(org.apache.kafka.streams.kstream.Initializer<VR> initializer, org.apache.kafka.streams.kstream.Aggregator<? super K,? super V,VR> aggregator)
     
    <VR> KTableX<K,VR>
    aggregate(org.apache.kafka.streams.kstream.Initializer<VR> initializer, org.apache.kafka.streams.kstream.Aggregator<? super K,? super V,VR> aggregator, MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
     
    <VR> KTableX<K,VR>
    aggregate(org.apache.kafka.streams.kstream.Initializer<VR> initializer, org.apache.kafka.streams.kstream.Aggregator<? super K,? super V,VR> aggregator, org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
     
    <VR> KTableX<K,VR>
    aggregate(org.apache.kafka.streams.kstream.Initializer<VR> initializer, org.apache.kafka.streams.kstream.Aggregator<? super K,? super V,VR> aggregator, org.apache.kafka.streams.kstream.Named named, MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
     
    <VR> KTableX<K,VR>
    aggregate(org.apache.kafka.streams.kstream.Initializer<VR> initializer, org.apache.kafka.streams.kstream.Aggregator<? super K,? super V,VR> aggregator, org.apache.kafka.streams.kstream.Named named, org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
     
    <VOut> CogroupedKStreamX<K,VOut>
    cogroup(org.apache.kafka.streams.kstream.Aggregator<? super K,? super V,VOut> aggregator)
     
    KTableX<K,Long>
    count()
     
    KTableX<K,Long>
    count(MaterializedX<K,Long,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
     
    KTableX<K,Long>
    count(org.apache.kafka.streams.kstream.Materialized<K,Long,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
     
    KTableX<K,Long>
    count(org.apache.kafka.streams.kstream.Named named)
     
    KTableX<K,Long>
    count(org.apache.kafka.streams.kstream.Named named, MaterializedX<K,Long,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
     
    KTableX<K,Long>
    count(org.apache.kafka.streams.kstream.Named named, org.apache.kafka.streams.kstream.Materialized<K,Long,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
     
    KTableX<K,V>
    reduce(org.apache.kafka.streams.kstream.Reducer<V> reducer)
     
    KTableX<K,V>
    reduce(org.apache.kafka.streams.kstream.Reducer<V> reducer, MaterializedX<K,V,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
     
    KTableX<K,V>
    reduce(org.apache.kafka.streams.kstream.Reducer<V> reducer, org.apache.kafka.streams.kstream.Materialized<K,V,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
     
    KTableX<K,V>
    reduce(org.apache.kafka.streams.kstream.Reducer<V> reducer, org.apache.kafka.streams.kstream.Named named, MaterializedX<K,V,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
     
    KTableX<K,V>
    reduce(org.apache.kafka.streams.kstream.Reducer<V> reducer, org.apache.kafka.streams.kstream.Named named, org.apache.kafka.streams.kstream.Materialized<K,V,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
     
    SessionWindowedKStreamX<K,V>
    windowedBy(org.apache.kafka.streams.kstream.SessionWindows windows)
     
    TimeWindowedKStreamX<K,V>
    windowedBy(org.apache.kafka.streams.kstream.SlidingWindows windows)
     
    <W extends org.apache.kafka.streams.kstream.Window>
    TimeWindowedKStreamX<K,V>
    windowedBy(org.apache.kafka.streams.kstream.Windows<W> windows)
     

  • Method Details

    • count

      KTableX<K,Long> count()
      Specified by:
      count in interface org.apache.kafka.streams.kstream.KGroupedStream<K,V>

    • count

      KTableX<K,Long> count(org.apache.kafka.streams.kstream.Named named)
      Specified by:
      count in interface org.apache.kafka.streams.kstream.KGroupedStream<K,V>

    • count

      KTableX<K,Long> count(org.apache.kafka.streams.kstream.Materialized<K,Long,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
      Specified by:
      count in interface org.apache.kafka.streams.kstream.KGroupedStream<K,V>

    • count

      KTableX<K,Long> count(MaterializedX<K,Long,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
      See Also:

    • count

      KTableX<K,Long> count(org.apache.kafka.streams.kstream.Named named, org.apache.kafka.streams.kstream.Materialized<K,Long,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
      Specified by:
      count in interface org.apache.kafka.streams.kstream.KGroupedStream<K,V>

    • count

      KTableX<K,Long> count(org.apache.kafka.streams.kstream.Named named, MaterializedX<K,Long,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
      See Also:

    • reduce

      KTableX<K,V> reduce(org.apache.kafka.streams.kstream.Reducer<V> reducer)
      Specified by:
      reduce in interface org.apache.kafka.streams.kstream.KGroupedStream<K,V>

    • reduce

      KTableX<K,V> reduce(org.apache.kafka.streams.kstream.Reducer<V> reducer, org.apache.kafka.streams.kstream.Materialized<K,V,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
      Specified by:
      reduce in interface org.apache.kafka.streams.kstream.KGroupedStream<K,V>

    • reduce

      KTableX<K,V> reduce(org.apache.kafka.streams.kstream.Reducer<V> reducer, MaterializedX<K,V,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
      See Also:

    • reduce

      KTableX<K,V> reduce(org.apache.kafka.streams.kstream.Reducer<V> reducer, org.apache.kafka.streams.kstream.Named named, org.apache.kafka.streams.kstream.Materialized<K,V,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
      Specified by:
      reduce in interface org.apache.kafka.streams.kstream.KGroupedStream<K,V>

    • reduce

      KTableX<K,V> reduce(org.apache.kafka.streams.kstream.Reducer<V> reducer, org.apache.kafka.streams.kstream.Named named, MaterializedX<K,V,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
      See Also:

    • aggregate

      <VR> KTableX<K,VR> aggregate(org.apache.kafka.streams.kstream.Initializer<VR> initializer, org.apache.kafka.streams.kstream.Aggregator<? super K,? super V,VR> aggregator)
      Specified by:
      aggregate in interface org.apache.kafka.streams.kstream.KGroupedStream<K,V>

    • aggregate

      <VR> KTableX<K,VR> aggregate(org.apache.kafka.streams.kstream.Initializer<VR> initializer, org.apache.kafka.streams.kstream.Aggregator<? super K,? super V,VR> aggregator, org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
      Specified by:
      aggregate in interface org.apache.kafka.streams.kstream.KGroupedStream<K,V>

    • aggregate

      <VR> KTableX<K,VR> aggregate(org.apache.kafka.streams.kstream.Initializer<VR> initializer, org.apache.kafka.streams.kstream.Aggregator<? super K,? super V,VR> aggregator, MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
      See Also:

    • aggregate

      <VR> KTableX<K,VR> aggregate(org.apache.kafka.streams.kstream.Initializer<VR> initializer, org.apache.kafka.streams.kstream.Aggregator<? super K,? super V,VR> aggregator, org.apache.kafka.streams.kstream.Named named, org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
      Specified by:
      aggregate in interface org.apache.kafka.streams.kstream.KGroupedStream<K,V>

    • aggregate

      <VR> KTableX<K,VR> aggregate(org.apache.kafka.streams.kstream.Initializer<VR> initializer, org.apache.kafka.streams.kstream.Aggregator<? super K,? super V,VR> aggregator, org.apache.kafka.streams.kstream.Named named, MaterializedX<K,VR,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
      See Also:

    • windowedBy

      <W extends org.apache.kafka.streams.kstream.Window> TimeWindowedKStreamX<K,V> windowedBy(org.apache.kafka.streams.kstream.Windows<W> windows)
      Specified by:
      windowedBy in interface org.apache.kafka.streams.kstream.KGroupedStream<K,V>

    • windowedBy

      TimeWindowedKStreamX<K,V> windowedBy(org.apache.kafka.streams.kstream.SlidingWindows windows)
      Specified by:
      windowedBy in interface org.apache.kafka.streams.kstream.KGroupedStream<K,V>

    • windowedBy

      SessionWindowedKStreamX<K,V> windowedBy(org.apache.kafka.streams.kstream.SessionWindows windows)
      Specified by:
      windowedBy in interface org.apache.kafka.streams.kstream.KGroupedStream<K,V>

    • cogroup

      <VOut> CogroupedKStreamX<K,VOut> cogroup(org.apache.kafka.streams.kstream.Aggregator<? super K,? super V,VOut> aggregator)
      Specified by:
      cogroup in interface org.apache.kafka.streams.kstream.KGroupedStream<K,V>