В настоящее время я работаю над фреймворком Java и Testng. Вот сначала мы определяем модель данных, такую как модель данных Erwin, с источником, целями и логикой преобразования. Затем во время выполнения мы публикуем данные по темам KAFKA и на основе модели данных создают пространства имен, темы (с фиксированным соглашением на именование) на схемах KAFKA и Source и Target. Поскольку мы используем одну и ту же модель данных на каждом запуска, исходная схема, целевая схема, имя темы Kafka остается одинаковым. Это работает хорошо, если перед каждым запуска мы чищаем темы и схему DB и запускаем следующий тестовый пример последовательно. Однако при запуске тестовых случаев параллельно, приводит к несоответствию данных и несоответствию данных, как те же темы и схема используются в тестовых случаях. Также KAFKA не находится под контролем настройки /модифицировать. Любая помощь ценится.
Подробнее здесь: https://stackoverflow.com/questions/795 ... f-the-test
