Хотим поднять кафку для того чтобы слушать наш сервер адрес:порт, куда нам будут присылать сообщения, которые мы потом хотим класть в базу. Для того чтобы кафка могла вот так сидеть и слушать конкретный адрес и добавлять его в топик нужен какой-то продьюсер, верно? Нет ли в кафке встроенного функционала для такой ситуации? Мне, как человеку не пользовавшимся брокером сообщений написание отдельного скрипта-продьюсера, который бы эти сообщения принимал и в топик клал кажется избыточным, почему бы тогда сразу он не перекладывал его в базу?
Также вопрос, если всё-таки идти по пути написания продьюсера, подойдёт ли питон скрипт, который будет в бесконечном цикле слушать адрес и цеплять сообщения или нужно поднимать полноценный веб-сервис на Django например, чтобы сообщения шли в него