Non classé

python 3.x – Comment créer un consommateur kafka indépendant du serveur Django

Le 21 avril 2019 - 1 minute de lecture

Je suis assez nouveau pour Python. J'ai une application Web basée sur Django dans laquelle j'effectue certaines tâches à l'aide de Kafka.
j'utilise confluent-kafka wrapper pour communiquer avec le courtier Kafka.

Donc, une fois qu'un sujet est créé sur le kafka courtier, J'assigne un consommateur pour qu'il s'abonne à ce processus, pour qu'il soit non bloquant, j'utilise multitraitement module afin que le consommateur s'exécute sur un thread séparé et ne bloque pas le thread principal de l'application.

Cependant, je ne suis pas sûr que se passera-t-il si mon serveur s'arrête? Le processus fonctionnera-t-il toujours de la même façon que les tâches cron, même si le serveur ne fonctionne pas?

Sinon, quelqu'un peut-il me suggérer comment déclencher mon consommateur pour qu'il soit indépendant de mon serveur Django?

Commentaires

Laisser un commentaire

Votre commentaire sera révisé par les administrateurs si besoin.