Получение (2006, 'MySQL server has gone away error') в потребителе kafka в моем django приложении

Недавно я написал kafka consumer в моем django проекте, который работает в фоновом режиме, и есть mysql запрос, который читает внутри потребителя, и процесс очень легкий, так как у меня не так много данных. Но я получаю (2006, 'MySQL server has gone away) и я не понимаю, почему именно это происходит и каково решение этой проблемы? Любая подсказка или решение для этого будут высоко оценены.

Ниже приведен мой код:-

`def job_listener():
    listener = KafkaConsumer(topic, group_id=group_id, bootstrap_servers=settings.KAFKA_BOOTSTRAP_SERVERS, auto_offset_reset=settings.KAFKA_AUTO_OFFSET_RESET, enable_auto_commit=settings.KAFKA_ENABLE_AUTO_COMMIT)

    for message in listener:
        try:
            data = json.loads(message.value)
            logger.info("Data Received {}".format(data))
        except Exception as e:
            data = None
            logger.error("Failed to parse the message with exception {}".format(e))
        if data is not None:
            try:
                Job.objects.get(pk=data['id']
                        except ObjectDoesNotExist:
                            logger.error("Keyword doesn't exist with data {}".format(data))
                   
                listener.commit({TopicPartition(topic, message.partition): OffsetAndMetadata(message.offset+1, '')})
            except Exception as e:
                logger.error(
                    "Failed to read data {} with exception {}".format(data, e))
                listener.seek(TopicPartition(topic,
                                             message.partition), message.offset)`

Вернуться на верх