У меня есть код, написанный полностью на scala, который использует потоковую передачу по искру для получения данных json из темы kafka, а затем после некоторой обработки выдает их в cassandra и другую тему kafka. Теперь мне нужно написать модульный тест для этого кода. Мне нужна помощь о том, как написать такой тест и как мы можем имитировать данные, когда я использую разъем искровой кассандры.