Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-2590 KIP-28: Kafka Streams Checklist
  3. KAFKA-3497

Streams ProcessorContext should support forward() based on child name

    Details

    • 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:

      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_r7vTctyMrGK4t1Lc0WnLqYmi0dhEcaog@mail.gmail.com>

        Attachments

          Activity

            People

            • Assignee:
              enothereska Eno Thereska
              Reporter:
              kawamuray Yuto Kawamura
            • Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: