Wie kann ich einen AWS-Kinesis-Stream auslagern?

Ich möchte gerne fanout / chain / replizieren eines Eingabe-AWS-Kinesis-Streams an N neue Kinesis-Streams, Damit jeder Datensatz, der in die Eingabe-Kinesis geschrieben wird, in jedem der N Streams erscheint.

Ist dort einAWS-Service oder eine Open Source-Lösung?

Ich schreibe lieber keinen Code, um das zu tun, wenn es eine fertige Lösung gibt.AWS Kinesis firehose ist keine Lösung, da keine Ausgabe in Kinesis möglich ist. Vielleicht eine AWS Lambda-Lösung, wenn der Betrieb nicht zu teuer ist?