The goal of KIP-307 is a different one. It's about providing names to make debugging easier.
Thus, I don't think "307 is doing it the wrong way" -- the question is, what problem is addressed, and KIP-307 addresses a different one as discussed on this question. -Matthias On 2/13/19 1:53 AM, Jan Filipiak wrote: > 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"); >> >> -----
signature.asc
Description: OpenPGP digital signature