Current state: Accepted Vote
Discussion thread: https://lists.apache.org/thread.html/a5ee2d569448dd57647dca93f288405c13785dec9cb4a0cbddfedd35@%3Cdev.kafka.apache.org%3E
JIRA: ,
For users who cannot read their source topic as a changelog stream from the beginning we need to provide a way for event streams to be translated into changelog stream. As pointed out by guozhang Wang this should not be confused with KStream.reduce(), these functions should:
Two functions will need to be added to the KStream interface:
//java KTable<K,V> toTable() KTable<K,V> toTable(Named) KTable<K,V> toTable(final Materialized<K, VR, KeyValueStore<Bytes, byte[]>> materialized) KTable<K,V> toTable(Named, final Materialized<K, VR, KeyValueStore<Bytes, byte[]>> materialized) //scala def toTable: KTable[K, V] def toTable(materialized: Materialized[K, V, ByteArrayKeyValueStore]): KTable[K, V] |
Adding two new functions to the Kstreams DSL.
No users will be impacted as this is just addition of two new methods.
None.