У нас есть долгосрочное задание по загрузке записей в Elasticsearch. Поскольку кластер ES выполняет маршрутизацию в полночь, приемник иногда дает сбой. Мы обрабатываем эти ошибки и повторно добавляем эти неудачные операции вставки в очередь и продолжаем вставлять их. Однако мы обнаружили, что обратное давление для источника становится выше, и операция контрольной точки наконец получает тайм-аут. Работа застрянет и больше не будет прогрессировать.
Есть идеи для решения этой проблемы? Большое спасибо!