Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Here comes the tricky part: in Kafka Streams, sometimes we may encounter the requirement of materializing a windowed topic. In the source processor point of view, the windowed topic input should be (Windowed<K> key, V value). So our discussion could actually extend to four cases:

...

  1. Non-windowed topic materialized to key-value store (the most common case)
  2. Non-windowed topic materialized to window store
  3. Windowed topic materialized to key-value store (rare case, but possible)
  4. Windowed topic materialized to window store

Here we want to be clear about case 2 and 4. When we materialize a windowed topic

...


Public Interfaces

The current KTable API looks like:

...