Не получаеться подключить Kafka к Postgress

Не получаеться подключить Kafka к Postgress.

У меня есть приложение которое работает вместе с бд Postgress запущенной на докере которая работает через SQLAlchemy и нужно интегрировать уже существующую бд с Кафка.
Пробовал через коннекторы но к сожалению не работает с уже существующей бд а так же пробовал создать пайплайны через веб сервис но он не видит локальный хост Postgress запущенный через докер. Написан весь сервис на пайтоне и через ORM без sql запросов.

Возможно кто-то уже делал такую интеграцию через SQLAlchemy? Как ее можно реализовать подскажите пожалуйста.