Guozhang Wang created KAFKA-3429:
------------------------------------
Summary: Remove Serdes needed for repartitioning in KTable
stateful operations
Key: KAFKA-3429
URL: https://issues.apache.org/jira/browse/KAFKA-3429
Project: Kafka
Issue Type: Sub-task
Reporter: Guozhang Wang
Fix For: 0.10.0.1
Currently in KTable stateful operations, we require the users to provide serdes
(default to configured ones) for repartitioning. However, these are not
necessary since for all KTable instances either generated from the topics
directly:
{code}builder.table(...){code}
or from aggregation operations:
{code}stream.aggregate(...){code}
There are already serde provided for materializing the data, and hence the same
serde can be re-used when the resulted KTable is involved in future stateful
operations. Implementation-wise we need to carry the serde information along
with the KTableImpl instance in order to do it.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
