Can I access the high level producer through this library?

[nodefluent]

Can I access the high level producer through this library?

[krystianity]

Hi @boriskogan81 yes you can access the producer.
However for what you want to achieve designing the final stream events in a key value structure would be the best way, as you can pass your desired partition and topic right with them.

https://github.com/nodefluent/kafka-streams/blob/master/lib/messageProduceHandle.js#L92

if you map your stream events to look like so: {key: "..", value: "..", partition: 0, topic: "my-topic" }
before calling to, you can control where they are produced to on a per-event-basis.