Das Projekt verarbeitet Finanzdaten: Eingabe ist synchron über API, dann asynchrone Kommunikation über Kafka. Wie würdest du seine Tests organisieren?