Jonathan Bender created KAFKA-3455:
--------------------------------------
Summary: Connect custom processors with the streams DSL
Key: KAFKA-3455
URL: https://issues.apache.org/jira/browse/KAFKA-3455
Project: Kafka
Issue Type: Sub-task
Components: kafka streams
Affects Versions: 0.9.0.1
Reporter: Jonathan Bender
>From the kafka users email thread, we discussed the idea of connecting custom
>processors with topologies defined from the Streams DSL (and being able to
>sink data from the processor). Possibly this could involve exposing the
>underlying processor's name in the streams DSL so it can be connected with the
>standard processor API.
{quote}
Thanks for the feedback. This is definitely something we wanted to support
in the Streams DSL.
One tricky thing, though, is that some operations do not translate to a
single processor, but a sub-graph of processors (think of a stream-stream
join, which is translated to actually 5 processors for windowing / state
queries / merging, each with a different internal name). So how to define
the API to return the processor name needs some more thinking.
{quote}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
