После перевода тестов на восемь параллельных потоков события «теряются»
Десять тестов проверяют события в общем топике тестового стенда. Каждый читает последние 50 сообщений и ищет событие с типом order_paid. После включения параллельного прогона тесты начали падать с «событие не найдено», хотя события в топике есть.
Что нужно изменить?
- Искать событие по уникальному идентификатору своих данных, а не по типу
- Запретить параллельный прогон для тестов, работающих с Kafka
- Увеличить число читаемых сообщений с 50 до 5000
- Давать каждому тесту свою группу потребителя