сети с Elastic, кафка не восстанавливает коннект с Elasticsearch. Рестарт кафки решает проблему. Такое поведение встречается у кого-то?
А что используется для связи кафки с эластиком? Там и искать
Юзаю kafka-connect-elasticsearch . Пока не удалось определить по логам в чем ошибка. Если это не типичное поведение kafka-connect и это только у нас, то пойду дальше копать.
посомтрите вот тут, нужно настроить политику ретраев, в некоторых случаях до суток по дефолту может вырасти промежуток ретрая https://github.com/confluentinc/kafka-connect-elasticsearch/blob/master/src/main/java/io/confluent/connect/elasticsearch/RetryUtil.java#L81 , но я тоже за кейс предложенный @Radik_Seyfullin
Обсуждают сегодня