For now, just use the name it gets automatically, or crack the
AbstractStream open with reflection ;)
307 is doing it the wrong way again, just make name accessible instead
of make the users put them :face_with_rolling_eyes:
On 08.02.2019 02:36, Guozhang Wang wrote:
> Hi Nan,
>
> Glad it helps with your case. Just another note that in the next release
> when KIP-307 is in place [1], you can actually combine the DSL with PAPI by
> naming the last operator that creates your transformed KStream, and then
> manually add the sink nodes like:
>
> stream2 = stream1.transform(Named.as("myName"));
>
> topology = builder.build();
>
> // continue adding to the built topology
> topology.addSink(... "myName");
>
> -----
