Alexey Romanchuk
Alexey Romanchuk
I like the idea. What about supporting `tag` and `push` command?
Ignore my comment. I read the docs carefully and found all I need. Sorry
Any thoughts when this can be implemented?
The example by provided link works fine to me
How should we deal with backward compatibility in this case? Should we change it only for 2.0 or 1.0 too?
Option 1 > complex wiring required, does not work without GraphDSL > Lets provide simple wrappers that exposes complex shapes as `Source` or as `Flow[Confirmation, Msg]`. Why this will not...
> The “simple wrappers” proposal does not work because the complexity is essential, it cannot be hidden. In particular it is impossible to break up the complex shape and offer...
> Concerning termination: that would need to be communicated back to the Source when it hits the confirmation input. This is of course trivial in Option 1, but the equivalent...
@ktoso got it. I will try to explain current situation in more details to be clear. Right now there are 3 API's in the reactive kafka's master: - RS API...
@rkuhn There are also two (optional) additional aspects we may warn about: - tracking assigned topics and partitions. Kafka supports multiple clients reading from the same topic and automatically balance...