Hi!

I was trying to build a topology using the DSL, add a custom processor and
then add a sink for it.  However, it seems like there's no great way to do
this using the APIs, since the processor's internal "name" is not exposed
in the KStream interface, and the .process method doesn't return the latest
KStream.

Is it possible to expose the underlying processor name from the builder
APIs, so that we could connect custom processors by referencing their names
directly?  I suppose you could also just make the return type of .process
into a KStream as well.

Cheers,
Jon

Reply via email to