[KAFKA-3497] Streams ProcessorContext should support forward() based on child name

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.10.0.1
• Fix Version/s: 0.10.0.0
• Component/s: streams
• Labels: api
• Assignee: Eno Thereska
• Reporter: Yuto Kawamura
• Created: 03/Apr/16 16:04
• Updated: 07/Apr/16 17:20
• Resolved: 07/Apr/16 17:20

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/<[e-mail]>