Eu gostaria defanout / encadear / replicar um fluxo de entrada do AWS Kinesis para N novos fluxos do Kinesis, Para que cada registro gravado no Kinesis de entrada apareça em cada um dos N fluxos.

Existe algumServiço da AWS ou uma solução de código aberto?

Prefiro não escrever código para fazer isso, se houver uma solução pronta.Mangueira de incêndio AWS Kinesis não é uma solução porque não pode gerar kinesis. Talvez uma solução AWS Lambda, se isso não for muito caro para executar?