Guozhang Wang created KAFKA-3430: ------------------------------------ Summary: Allow users to set key in KTable.toStream() and KStream Key: KAFKA-3430 URL: https://issues.apache.org/jira/browse/KAFKA-3430 Project: Kafka Issue Type: Sub-task Reporter: Guozhang Wang Fix For: 0.10.0.1
Currently KTable.toStream does not take any parameters and hence users who wants to set the key need to do two steps: {code}table.toStream().map(...){code} in order to do so. We can make it in one step by providing the mapper parameter in toStream. And similarly today users usually need to call {code} KStream.map() {code} in order to select the key before aggregation-by-key operation if the original stream is does not contain keys. We can consider adding a specific function in KStream to do so: {code}KStream.selectKey(mapper){code} which essential is the same as {code}KStream.map(mapper, value){code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)