пойти по пути интеграционных тестов? в обход проверки непосредственно самого сообщения в топике кафки?
Тут надо понять почему вы конкретно это хотите тестировать, что именно делает сервис, почему вы хотите это делать частью CI. Может, тут есть эксперты по e2e тестам, которые меня поправят, но я бы просто проверят что паблиш в кафку происходит, как юнит и/или интеграционный тест. То есть, можно паблишить в реальную кафку, но существующую только для тестов, не продакшен. А в продакшене можно например добавить метрики когда такой-то сервис паблишит сообщение в кафку и (например!) настроить алерт если за сутки было 0 сообщений, или еще сделать что-то такое (я просто не знаю какая у вас логика приложения, нагрузка и тд)
И еще хорошо бы понимать что кафка это не хранилище, а всеголишь транспорт и не надо его тестировать и в нем искать данные как
Обсуждают сегодня