Ignition Request Queues use Kafka topics to provide a request queue mechanism for drivers that need it e.g. the Ansible Driver. This can be tricky to configure because the max_poll_interval_ms needs to be set to higher that the maximum time request execution is expected to take, to prevent Kafka topic rebalancing. Instead, we should consider using consumer pause and resume for this - see https://kafka-python.readthedocs.io/en/master/apidoc/KafkaConsumer.html.
Ignition Request Queues use Kafka topics to provide a request queue mechanism for drivers that need it e.g. the Ansible Driver. This can be tricky to configure because the
max_poll_interval_msneeds to be set to higher that the maximum time request execution is expected to take, to prevent Kafka topic rebalancing. Instead, we should consider using consumerpauseandresumefor this - see https://kafka-python.readthedocs.io/en/master/apidoc/KafkaConsumer.html.