I'd also have a follow-up question:
> Actually, the set of subtypes is not known in advance this is why I need
> compute output topics from messages. So the branch method is of any help
> in my context.
For a number of reasons we recommend pre-creating input, intermediate, and
We can consider adding this feature to with a StreamsAdminClient that we
are adding as part of KAFKA-4060. However, I'm still not sure if it should
be added on the DSL layer or on the Processor API layer.
Florian, what do you mean that the Processor is not "completely safe"? Do
you mean not
Thank you Matthias for your answers.
The mailing list that you linked shows a solution using the Processor API.
Actually, the set of subtypes is not known in advance this is why I need to
compute output topics from messages. So the branch method is of any help in
I think, this
Do you know the set of subtypes in advance? I.e, could you use:
KStream branches = stream.branch(predicates);
to split the stream based on the subtypes?
On Tue, 18 Oct 2016 at 00:43 Matthias J. Sax wrote:
> -BEGIN PGP SIGNED
-BEGIN PGP SIGNED MESSAGE-
using DSL you cannot do this. However, if you use Processor API you can.
There are similar question on the mailing list already. For example: