Народ, привет Пишу интеграционные тесты с kafka в docker container. Spring

Java.
Решил попробовать задать весь контекст через @Import.

Столкнулся с проблемой: Отправляю сообщение в топик.
Сообщение сериализуется. Затем десериализуется (то есть доходит до топика-адресата)
Но почему-то не попадает ни в фильтры, ни в лиснеры.

Подскажите, куда можно копнуть?

Если после десериализации пойти дальше по шагам, под капотом в какой-то момент дохожу к месту, где вижу что на топике нет прикрепленных лиснеров. Действо происходит в DefaultKafkaConsumerFactory.createKafkaConsumer()
this.listeners.size == 0

а листенер смотрит на правильный хост кафки? если не ошибаюсь, с докером нужно было указывать что-то типа host.docker.internal в качестве хоста

Он имеет ввиду @KafkaListener из спринга

Можно как-то в режиме дебага убедиться наверняка? Точно смотрит на нужный тестовый токен, откуда есть предположение что подключается именно нужная тестовая фабрика с конфигами для тестов

да, но в пропертях же указывается адреса брокеров

Да, они подтягиваются из бустрапа, айдишники верные Иначе мы бы не дошли до десериализации, насколько я понимаю

хм, а при запущенном приложении все работает и только в тестах не получается? или пока не проверяли?