Class Grouped<K,​V>

    • Field Detail

      • keySerde

        protected final Serde<K> keySerde
      • valueSerde

        protected final Serde<V> valueSerde
      • name

        protected final String name
    • Constructor Detail

      • Grouped

        protected Grouped​(Grouped<K,​V> grouped)
    • Method Detail

      • with

        public static <K,​V> Grouped<K,​V> with​(String name,
                                                          Serde<K> keySerde,
                                                          Serde<V> valueSerde)
        Create a Grouped instance with the provided name, keySerde, and valueSerde. If the keySerde and/or the valueSerde is null the default value for the respective serde from config will be used.
        Parameters:
        name - the name used as part of the repartition topic name if required
        keySerde - the Serde used for serializing the key. If null the default key serde from config will be used
        valueSerde - the Serde used for serializing the value. If null the default value serde from config will be used
        Returns:
        a new Grouped configured with the name, keySerde, and valueSerde
        See Also:
        KStream.groupByKey(Grouped), KStream.groupBy(KeyValueMapper, Grouped), KTable.groupBy(KeyValueMapper, Grouped)
      • withName

        public Grouped<K,​V> withName​(String name)
        Perform the grouping operation with the name for a repartition topic if required. Note that Kafka Streams does not always create repartition topics for grouping operations.
        Parameters:
        name - the name used for the processor name and as part of the repartition topic name if required
        Returns:
        a new Grouped instance configured with the name
      • withKeySerde

        public Grouped<K,​V> withKeySerde​(Serde<K> keySerde)
        Perform the grouping operation using the provided keySerde for serializing the key.
        Parameters:
        keySerde - Serde to use for serializing the key. If null the default key serde from config will be used
        Returns:
        a new Grouped instance configured with the keySerde
      • withValueSerde

        public Grouped<K,​V> withValueSerde​(Serde<V> valueSerde)
        Perform the grouping operation using the provided valueSerde for serializing the value.
        Parameters:
        valueSerde - Serde to use for serializing the value. If null the default value serde from config will be used
        Returns:
        a new Grouped instance configured with the valueSerde