Package com.bakdata.kafka.streams.kstream

Interface BranchedKStreamX<K,V>

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

  • Method Details

    • branch

      BranchedKStreamX<K,V> branch(org.apache.kafka.streams.kstream.Predicate<? super K,? super V> predicate)
      Specified by:
      branch in interface org.apache.kafka.streams.kstream.BranchedKStream<K,V>

    • branch

      BranchedKStreamX<K,V> branch(org.apache.kafka.streams.kstream.Predicate<? super K,? super V> predicate, org.apache.kafka.streams.kstream.Branched<K,V> branched)
      Specified by:
      branch in interface org.apache.kafka.streams.kstream.BranchedKStream<K,V>

    • branch

      BranchedKStreamX<K,V> branch(org.apache.kafka.streams.kstream.Predicate<? super K,? super V> predicate, BranchedX<K,V> branched)
      See Also:

    • defaultBranch

      @Deprecated(since="4.0.0") Map<String,org.apache.kafka.streams.kstream.KStream<K,V>> defaultBranch()
      Deprecated.
      Use defaultBranchX() instead.
      Specified by:
      defaultBranch in interface org.apache.kafka.streams.kstream.BranchedKStream<K,V>

    • defaultBranchX

      Map<String,KStreamX<K,V>> defaultBranchX()
      See Also:
      • BranchedKStream.defaultBranch()

    • defaultBranch

      @Deprecated(since="4.0.0") Map<String,org.apache.kafka.streams.kstream.KStream<K,V>> defaultBranch(org.apache.kafka.streams.kstream.Branched<K,V> branched)
      Deprecated.
      Use defaultBranchX(Branched) instead.
      Specified by:
      defaultBranch in interface org.apache.kafka.streams.kstream.BranchedKStream<K,V>

    • defaultBranchX

      Map<String,KStreamX<K,V>> defaultBranchX(org.apache.kafka.streams.kstream.Branched<K,V> branched)
      See Also:
      • BranchedKStream.defaultBranch(Branched)

    • defaultBranch

      Map<String,KStreamX<K,V>> defaultBranch(BranchedX<K,V> branched)
      See Also:

    • noDefaultBranch

      @Deprecated(since="4.0.0") Map<String,org.apache.kafka.streams.kstream.KStream<K,V>> noDefaultBranch()
      Deprecated.
      Use noDefaultBranchX() instead.
      Specified by:
      noDefaultBranch in interface org.apache.kafka.streams.kstream.BranchedKStream<K,V>

    • noDefaultBranchX

      Map<String,KStreamX<K,V>> noDefaultBranchX()
      See Also:
      • BranchedKStream.noDefaultBranch()