[jira] [Created] (KAFKA-3477) Add customizable StreamPartition into #to functions of Streams DSL

[Guozhang Wang (JIRA)]

Guozhang Wang created KAFKA-3477:
------------------------------------

             Summary: Add customizable StreamPartition into #to functions of 
Streams DSL
                 Key: KAFKA-3477
                 URL: https://issues.apache.org/jira/browse/KAFKA-3477
             Project: Kafka
          Issue Type: Sub-task
            Reporter: Guozhang Wang
             Fix For: 0.10.0.1


In the lower-level Processor API we allow users to pass in a customizable 
StreamPartitioner when creating a new sink processor node to the topology:

{code}
builder.addSink(String name, String topic, StreamPartitioner partitioner, 
String... parentNames));
{code}

This StreamPartitioner allows users to specify any partitioning schemes based 
on record values instead of using the default behavior of hashing on the 
message key; but it is not exposed in the higher-level Streams DSL.

We can add this parameter to the Streams DSL as well:

{code}
KStream#to(String topic, StreamPartitioner partitioner);
KTable#to(String topic, StreamPartitioner partitioner);
{code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)