Вы можете создать системный сервис MyKafkaConsumer.service
в /etc/systemd/system
со следующим содержимым:
[Unit]
Description=A Kafka Consumer written in Python
After=network.target # include any other pre-requisites
[Service]
Type=simple
User=your_user
Group=your_user_group
WorkingDirectory=/path/to/your/consumer
ExecStart=python consumer.py
TimeoutStopSec=180
Restart=on-failure
RestartSec=5
[Install]
WantedBy=multi-user.target
Чтобы запустить службу (и настроить ее для запуска при загрузке), вы должны запустить
systemctl enable MyKafkaConsumer.service
systemctl start MyKafkaConsumer.service
Чтобы проверить его статус:
systemctl status MyKafkaConsumer
А чтобы посмотреть логи:
journactl -u MyKafkaConsumer -f
(или если вы хотите увидеть последние 100 строк)
journalctl -u MyKafkaConsumer -n 100
Вам необходимо создать аналогичную услугу и для вашего производителя.
Существует множество вариантов системных служб. Вы можете обратиться к этой статье , если вам нужны дальнейшие разъяснения. Не должно быть трудно найти руководства и дополнительные материалы в Интернете, хотя.