Package com.bakdata.kafka.streams.kstream

Class ConsumedX<K,V>

java.lang.Object
com.bakdata.kafka.streams.kstream.ConsumedX<K,V>
Type Parameters:
K - type of keys
V - type of values
public final class ConsumedX<K,V> extends Object
Use Preconfigured to lazily configure Serde for Consumed using Configurator
See Also:
  • Consumed

  • Method Summary

    Modifier and Type
    Method
    Description
    static <K, V> ConsumedX<K,V>
    as(String processorName)
     
    static <K, V> ConsumedX<K,V>
    keySerde(com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<K>> keySerde)
    Create an instance of ConsumedX with provided key serde
    static <K, V> ConsumedX<K,V>
    keySerde(org.apache.kafka.common.serialization.Serde<K> keySerde)
    Create an instance of ConsumedX with provided key serde
    protected final ConsumedX<K,V>
    modify(BiFunction<? super org.apache.kafka.streams.kstream.Consumed<K,V>,? super com.bakdata.kafka.Configurator,? extends org.apache.kafka.streams.kstream.Consumed<K,V>> modifier)
     
    protected final ConsumedX<K,V>
    modify(Function<? super org.apache.kafka.streams.kstream.Consumed<K,V>,? extends org.apache.kafka.streams.kstream.Consumed<K,V>> modifier)
     
    protected ConsumedX<K,V>
    newInstance(Function<com.bakdata.kafka.Configurator,org.apache.kafka.streams.kstream.Consumed<K,V>> initializer)
     
    static <K, V> ConsumedX<K,V>
    valueSerde(com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<V>> valueSerde)
    Create an instance of ConsumedX with provided value serde
    static <K, V> ConsumedX<K,V>
    valueSerde(org.apache.kafka.common.serialization.Serde<V> valueSerde)
    Create an instance of ConsumedX with provided value serde
    static <K, V> ConsumedX<K,V>
    with(com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<K>> keySerde, com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<V>> valueSerde)
     
    static <K, V> ConsumedX<K,V>
    with(org.apache.kafka.common.serialization.Serde<K> keySerde, org.apache.kafka.common.serialization.Serde<V> valueSerde)
     
    static <K, V> ConsumedX<K,V>
    with(org.apache.kafka.streams.AutoOffsetReset resetPolicy)
     
    static <K, V> ConsumedX<K,V>
    with(org.apache.kafka.streams.processor.TimestampExtractor timestampExtractor)
     
    static <K, V> ConsumedX<K,V>
    with(org.apache.kafka.streams.Topology.AutoOffsetReset resetPolicy)
    Deprecated.
    ConsumedX<K,V>
    withKeySerde(com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<K>> keySerde)
     
    ConsumedX<K,V>
    withKeySerde(org.apache.kafka.common.serialization.Serde<K> keySerde)
     
    ConsumedX<K,V>
    withName(String processorName)
     
    ConsumedX<K,V>
    withOffsetResetPolicy(org.apache.kafka.streams.AutoOffsetReset offsetResetPolicy)
     
    ConsumedX<K,V>
    withOffsetResetPolicy(org.apache.kafka.streams.Topology.AutoOffsetReset offsetResetPolicy)
    Deprecated.
    ConsumedX<K,V>
    withTimestampExtractor(org.apache.kafka.streams.processor.TimestampExtractor timestampExtractor)
     
    ConsumedX<K,V>
    withValueSerde(com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<V>> valueSerde)
     
    ConsumedX<K,V>
    withValueSerde(org.apache.kafka.common.serialization.Serde<V> valueSerde)
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Method Details

    • keySerde

      public static <K, V> ConsumedX<K,V> keySerde(com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<K>> keySerde)
      Create an instance of ConsumedX with provided key serde
      Type Parameters:
      K - type of keys
      V - type of values
      Parameters:
      keySerde - Serde to use for keys
      Returns:
      a new instance of ConsumedX

    • keySerde

      public static <K, V> ConsumedX<K,V> keySerde(org.apache.kafka.common.serialization.Serde<K> keySerde)
      Create an instance of ConsumedX with provided key serde
      Type Parameters:
      K - type of keys
      V - type of values
      Parameters:
      keySerde - Serde to use for keys
      Returns:
      a new instance of ConsumedX

    • valueSerde

      public static <K, V> ConsumedX<K,V> valueSerde(com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<V>> valueSerde)
      Create an instance of ConsumedX with provided value serde
      Type Parameters:
      K - type of keys
      V - type of values
      Parameters:
      valueSerde - Serde to use for values
      Returns:
      a new instance of ConsumedX

    • valueSerde

      public static <K, V> ConsumedX<K,V> valueSerde(org.apache.kafka.common.serialization.Serde<V> valueSerde)
      Create an instance of ConsumedX with provided value serde
      Type Parameters:
      K - type of keys
      V - type of values
      Parameters:
      valueSerde - Serde to use for values
      Returns:
      a new instance of ConsumedX

    • with

      public static <K, V> ConsumedX<K,V> with(com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<K>> keySerde, com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<V>> valueSerde)
      See Also:
      • Consumed.with(Serde, Serde)

    • with

      public static <K, V> ConsumedX<K,V> with(org.apache.kafka.common.serialization.Serde<K> keySerde, org.apache.kafka.common.serialization.Serde<V> valueSerde)
      See Also:
      • Consumed.with(Serde, Serde)

    • with

      public static <K, V> ConsumedX<K,V> with(org.apache.kafka.streams.processor.TimestampExtractor timestampExtractor)
      See Also:
      • Consumed.with(TimestampExtractor)

    • with

      @Deprecated(since="5.0.0") public static <K, V> ConsumedX<K,V> with(org.apache.kafka.streams.Topology.AutoOffsetReset resetPolicy)
      Deprecated.
      See Also:
      • Consumed.with(Topology.AutoOffsetReset)

    • with

      public static <K, V> ConsumedX<K,V> with(org.apache.kafka.streams.AutoOffsetReset resetPolicy)
      See Also:
      • Consumed.with(AutoOffsetReset)

    • as

      public static <K, V> ConsumedX<K,V> as(String processorName)
      See Also:
      • Consumed.as(String)

    • withKeySerde

      public ConsumedX<K,V> withKeySerde(com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<K>> keySerde)
      See Also:
      • Consumed.withKeySerde(Serde)

    • withKeySerde

      public ConsumedX<K,V> withKeySerde(org.apache.kafka.common.serialization.Serde<K> keySerde)
      See Also:
      • Consumed.withKeySerde(Serde)

    • withValueSerde

      public ConsumedX<K,V> withValueSerde(com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<V>> valueSerde)
      See Also:
      • Consumed.withValueSerde(Serde)

    • withValueSerde

      public ConsumedX<K,V> withValueSerde(org.apache.kafka.common.serialization.Serde<V> valueSerde)
      See Also:
      • Consumed.withValueSerde(Serde)

    • withOffsetResetPolicy

      public ConsumedX<K,V> withOffsetResetPolicy(org.apache.kafka.streams.AutoOffsetReset offsetResetPolicy)
      See Also:
      • Consumed.withOffsetResetPolicy(AutoOffsetReset)

    • withOffsetResetPolicy

      @Deprecated(since="5.0.0") public ConsumedX<K,V> withOffsetResetPolicy(org.apache.kafka.streams.Topology.AutoOffsetReset offsetResetPolicy)
      Deprecated.
      See Also:
      • Consumed.withOffsetResetPolicy(Topology.AutoOffsetReset)

    • withTimestampExtractor

      public ConsumedX<K,V> withTimestampExtractor(org.apache.kafka.streams.processor.TimestampExtractor timestampExtractor)
      See Also:
      • Consumed.withTimestampExtractor(TimestampExtractor)

    • withName

      public ConsumedX<K,V> withName(String processorName)
      See Also:
      • Consumed.withName(String)

    • newInstance

      protected ConsumedX<K,V> newInstance(Function<com.bakdata.kafka.Configurator,org.apache.kafka.streams.kstream.Consumed<K,V>> initializer)

    • modify

      protected final ConsumedX<K,V> modify(BiFunction<? super org.apache.kafka.streams.kstream.Consumed<K,V>,? super com.bakdata.kafka.Configurator,? extends org.apache.kafka.streams.kstream.Consumed<K,V>> modifier)

    • modify

      protected final ConsumedX<K,V> modify(Function<? super org.apache.kafka.streams.kstream.Consumed<K,V>,? extends org.apache.kafka.streams.kstream.Consumed<K,V>> modifier)