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"); > > -----