Package com.bakdata.kafka.streams.kstream

Class RepartitionedX<K,V>

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

  • Method Details

    • keySerde

      public static <K, V> RepartitionedX<K,V> keySerde(com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<K>> keySerde)
      Create an instance of RepartitionedX 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 RepartitionedX

    • keySerde

      public static <K, V> RepartitionedX<K,V> keySerde(org.apache.kafka.common.serialization.Serde<K> keySerde)
      Create an instance of RepartitionedX 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 RepartitionedX

    • valueSerde

      public static <K, V> RepartitionedX<K,V> valueSerde(com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<V>> valueSerde)
      Create an instance of RepartitionedX 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 RepartitionedX

    • valueSerde

      public static <K, V> RepartitionedX<K,V> valueSerde(org.apache.kafka.common.serialization.Serde<V> valueSerde)
      Create an instance of RepartitionedX 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 RepartitionedX

    • with

      public static <K, V> RepartitionedX<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:
      • Repartitioned.with(Serde, Serde)

    • with

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

    • as

      public static <K, V> RepartitionedX<K,V> as(String name)
      See Also:
      • Repartitioned.as(String)

    • numberOfPartitions

      public static <K, V> RepartitionedX<K,V> numberOfPartitions(int numberOfPartitions)
      See Also:
      • Repartitioned.numberOfPartitions(int)

    • streamPartitioner

      public static <K, V> RepartitionedX<K,V> streamPartitioner(org.apache.kafka.streams.processor.StreamPartitioner<K,V> partitioner)
      See Also:
      • Repartitioned.streamPartitioner(StreamPartitioner)

    • withNumberOfPartitions

      public RepartitionedX<K,V> withNumberOfPartitions(int numberOfPartitions)
      See Also:
      • Repartitioned.withNumberOfPartitions(int)

    • withKeySerde

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

    • withKeySerde

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

    • withValueSerde

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

    • withValueSerde

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

    • withStreamPartitioner

      public RepartitionedX<K,V> withStreamPartitioner(org.apache.kafka.streams.processor.StreamPartitioner<K,V> partitioner)
      See Also:
      • Repartitioned.withStreamPartitioner(StreamPartitioner)

    • withName

      public RepartitionedX<K,V> withName(String name)
      See Also:
      • Repartitioned.withName(String)

    • newInstance

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

    • modify

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

    • modify

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