The project processes financial data: input is synchronous via API, then asynchronous communication via Kafka. How would you organize its testing?