ли в Kafka Streams функциональность, позволяющая динамически соединять один входной поток с несколькими выходными потоками?KStream.branch позволяет ветвление на основе предикатов true / false, но это не совсем то, что я хочу. Мне бы хотелось, чтобы каждый входящий журнал определял тему, по которой он будет передаваться во время выполнения, например журнал{"date": "2017-01-01"} будет транслироваться в темуtopic-2017-01-01 и журнал{"date": "2017-01-02"} будет транслироваться в темуtopic-2017-01-02.

Я мог позвонитьforEach в потоке, затем напишите производителю Kafka, но это не кажется очень изящным. Есть ли лучший способ сделать это в рамках Streams?