Grouped

Grouped Scala object is part of Scala API for Kafka Streams that defines with factory methods for creating Grouped instances with key and value Serdes objects available in implicit scope.

Grouped’s "with" Factory Methods
// Note the backticks to use "with" reserved keyword
// GroupedJ is simply an import alias for the Java-aware Grouped

`with`[K, V](
  implicit keySerde: Serde[K], valueSerde: Serde[V]): GroupedJ[K, V]

`with`[K, V](name: String)(
  implicit keySerde: Serde[K], valueSerde: Serde[V]): GroupedJ[K, V]
Example: Creating Grouped Instance using Scala API for Kafka Streams
import org.apache.kafka.streams.scala._
import ImplicitConversions._
import Serdes._

import org.apache.kafka.streams.scala.kstream.Grouped
val grouped = Grouped.`with`[Long, String]

scala> :type grouped
org.apache.kafka.streams.kstream.Grouped[Long,String]
Tip
Read up on Implicit Parameters.

results matching ""

    No results matching ""