Аааа

мне надо чтоб другие контейнеры ждали - пока запустится один

ну я попробовал разные способы - не работает оно с докером

docker-compose

ну нашел скриптик

!

а я через что делаю?

Плохо делаешь

depend_on не работает

он все равно запускает, там нужен checker

я пробовал запускать через healthcheck - тоже не вижу результата

Аппка умирает если нет коннекта?

Если да - поставить рестарт

долго подниматься будет там же spring

лучше все токи проверка на health

А расскажи подробнее где это выстрелило?:) мы тоже решили, что dual write плохо и сразу без него сделали, теперь проблемы только в теории знаем, но интересно услышать живые примеры

Коллеги, столкнулся со странной ситуацией: не из всех партишенов в топике удаляются данные согласно установленному на топик retention.ms.
Кластер из 4х брокеров kafka_2.11, 8 партиций в топике, фактор репликации 2. Ретeншн на топик - 6 часов. В итоге сейчас в одной партиции нет данных старше 6 часов, в двух - старше 12 часов, в остальных данные двухдневной давности.
Картинка с размерами партиций для иллюстрации.
Подскажите, пожалуйста, куда копать и что крутить?

А сегментов сколько ? Какие настройки по сегментации ? log.segment.bytes? lsegment.ms ?

Данные в партициях разбиты по сегментам (файлам на диске). Кафка не удаляет активные сегменты (те те, в которые сейчас идёт запись) и периодически создаёт новые сегменты, делая их активными
Если вы хотите примерно 6 часов, настройте ротацию сегментов более частую или их размер поменьше сделайте (дефолтный - гигабайт)

если есть деньги - купите Skyrim Confluent replicator