[
https://issues.apache.org/jira/browse/KAFKA-3497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuto Kawamura updated KAFKA-3497:
---------------------------------
Description:
Currently {{ProcessorContext}} only supports {{forward(K, V)}} which forwards
KV to all children and {{forward(K, V, int childIndex)}} which forwards KV to
specific children that is identified by an index of children List.
While letting a Processor to issue messages which have arbitrary different
downstream destination, it is not handy to keep ordering of calling
{{addProcessor}}(or {{addSink}}) and childIndex consistent.
Here I'd like to suggest introducing another signature {{forward(K, V, String
childName)}} which allows to use child name(first argument to addProcessor or
addSink) to indicate the destination downstream.
Thread on user mailing list:
http://mail-archives.apache.org/mod_mbox/kafka-users/201604.mbox/<caczvatp5kgeftap46_r7vtctymrgk4t1lc0wnlqymi0dhec...@mail.gmail.com>
was:
Currently {{ProcessorContext}} only supports {{forward(K, V)}} which forwards
KV to all children and {{forward(K, V, int childIndex}} which forwards KV to
specific children that is identified by an index of children List.
While letting a Processor to issue messages which have arbitrary different
downstream destination, it is not handy to keep ordering of calling
{{addProcessor}}(or {{addSink}}) and childIndex consistent.
Here I'd like to suggest introducing another signature {{forward(K, V, String
childName)}} which allows to use child name(first argument to addProcessor or
addSink) to indicate the destination downstream.
Thread on user mailing list:
http://mail-archives.apache.org/mod_mbox/kafka-users/201604.mbox/<caczvatp5kgeftap46_r7vtctymrgk4t1lc0wnlqymi0dhec...@mail.gmail.com>
> Streams ProcessorContext should support forward() based on child name
> ---------------------------------------------------------------------
>
> Key: KAFKA-3497
> URL: https://issues.apache.org/jira/browse/KAFKA-3497
> Project: Kafka
> Issue Type: Improvement
> Components: kafka streams
> Affects Versions: 0.10.0.1
> Reporter: Yuto Kawamura
>
> Currently {{ProcessorContext}} only supports {{forward(K, V)}} which forwards
> KV to all children and {{forward(K, V, int childIndex)}} which forwards KV to
> specific children that is identified by an index of children List.
> While letting a Processor to issue messages which have arbitrary different
> downstream destination, it is not handy to keep ordering of calling
> {{addProcessor}}(or {{addSink}}) and childIndex consistent.
> Here I'd like to suggest introducing another signature {{forward(K, V, String
> childName)}} which allows to use child name(first argument to addProcessor or
> addSink) to indicate the destination downstream.
> Thread on user mailing list:
> http://mail-archives.apache.org/mod_mbox/kafka-users/201604.mbox/<caczvatp5kgeftap46_r7vtctymrgk4t1lc0wnlqymi0dhec...@mail.gmail.com>
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
