Автотест не находит событие, хотя kcat показывает его в топике
Тест делает три шага: вызывает API оплаты, затем подключается к топику и читает сообщения с настройкой auto.offset.reset = latest, затем ищет своё событие. Событие не находится, но после падения теста kcat -o beginning показывает его в топике.
В чём причина?
- Консьюмер подключился после отправки и читает только новые сообщения
- Событие попало в другую партицию, а консьюмер читает только первую
- kcat показывает сообщения из своего кэша, в топике их уже нет
- Событие было отправлено без ключа, поэтому обычный консьюмер его не видит