Best practices for deploying Faust agent using Kubernetes

Checklist

• [ X] I have included information about relevant versions
• I have verified that the issue persists when using the master branch of Faust.

Steps to reproduce

I am trying to deploy a Faust agent to production env using 2 pods. The agent consumes from a topic that has 6 partitions. After the deploy the agent runs until it receives a SIGTERM(15) and the agent shut downs and stops consuming messages.

I am wondering if there are any best practices around deploys using kubernetes.

Expected behavior

Agent gracefully handles the sigterm.

Actual behavior

App shuts down and stop consuming messages

Versions

• Python version: 3.7
• Faust version: 1.10.4