Versions Compared

Old Version 5

changes.mady.by.user Joan Goyeau

Saved on

compared with

New Version 6

changes.mady.by.user Joan Goyeau

Saved on

Key

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

...

I've proposed when Kafka Stream's Scala API was not released yet to solve the serdes issue on functions that takes a materialized (count, reduce and aggregate) to just make the materialized implicit and have a default implicit in ImplicitConversions that had the serdes filled in:.

Given the following definitions:
defcount()(implicitmaterialized: Materialized[K, Long, ByteArrayKeyValueStore])
defreduce(reducer: (V, V) =>V)(implicitmaterialized: Materialized[K, V, ByteArrayKeyValueStore])
defaggregate[VR](initializer: =>VR)(aggregator: (K, V, VR) =>VR)(implicitmaterialized: Materialized[K, VR, ByteArrayKeyValueStore])

...