Python aiokafka – как установить максимальный лимит повторов для каждого сообщения?
Я использую aiokafka 0.8.0 в Python 3.9 для изучения темы Kafka.
Иногда обработка завершается сбоем, что обычно рассматривается как исключение Retryable, поэтому вскоре после этого сообщение отправляется снова.
Однако в некоторых случаях исключение на самом деле не является Retryable, и его трудно различить во время выполнения.
Я хотел бы установить максимальный лимит повторов, скажем, 5-10, чтобы избежать бесконечных циклов в этом случае.
Используя aiokafka, как я могу: а) установить ограничение повторных попыток; или б) получить информацию о количестве повторов сообщения, чтобы я мог проверить это и повторить попытку самостоятельно?