Existe funcionalidade incorporada ao Kafka Streams que permite conectar dinamicamente um único fluxo de entrada a vários fluxos de saída?KStream.branch permite ramificação com base em predicados verdadeiro / falso, mas não é exatamente isso que eu quero. Gostaria que cada log recebido determinasse o tópico para o qual ele será transmitido em tempo de execução, por exemplo, um log{"date": "2017-01-01"} será transmitido para o tópicotopic-2017-01-01 e um log{"date": "2017-01-02"} será transmitido para o tópicotopic-2017-01-02.

Eu poderia ligarforEach no fluxo, escreva para um produtor Kafka, mas isso não parece muito elegante. Existe uma maneira melhor de fazer isso dentro da estrutura do Streams?