Testcontainers/embedded/mock consumer, контрактные тесты схем, интеграционные с коротким топиком; проверяйте идемпотентность и ретраи, не только happy path.
Разбор
- Фикстуры сообщений версионируйте.
- Симулируйте rebalance и дубликаты.
- Не зависьте от shared dev-кластера без изоляции.
- Нагрузочные тесты — отдельно.
Итог
Тесты стриминга покрывают дубли, схемы и сбои, не только deserialize.
