TGViewer
Сочный DevOps Сочный DevOps @andtree_sec · 420 subscribers
Post #183 141
Переносим данные kafka на RAID

Один из кластеров kafka пишет свои данные в /var/lib/kafka/, который в root. Пришла задача исправить, есть 8 дисков под программный raid. Соответственно будет делать 10-й.

Подготовительные работы.
Работы проводятся поочередно на каждом брокере. Сначала отключаем брокер и переносим данные в новую временную директорию.
systemctl stop kafka
mkdir /tmp/kafka_backup
rsync -aXH --progress /var/lib/kafka/ /tmp/kafka_backup
rm -rf /var/lib/kafka/*


Далее можно воспользоваться вот этой ansible ролью для установки mdadm.
Мои переменные
mdadm_arrays:
- name: "md1"
devices:
- '/dev/nvme1n1'
- '/dev/nvme4n1'
- '/dev/nvme5n1'
- '/dev/nvme11n1'
- '/dev/nvme6n1'
- '/dev/nvme7n1'
- '/dev/nvme9n1'
- '/dev/nvme8n1'
filesystem: "xfs"
level: "10"
mountpoint: "/var/lib/kafka"
state: "present"
mdadm_force_create_filesystem: true


Это установит mdadm, создаст 10 RAID и сразу выполнит маунт в /var/lib/kafka.

Далее остается только перенести данные и включить брокер:
rsync -aXH --progress /tmp/kafka_backup/ /var/lib/kafka/
systemctl start kafka


#kafka
  • 🔥 1
More from @andtree_sec
  1. Sep 7, 2026Давненько не было сообщений. Скорее всего в будущем они уйдут в telegraf, который я еще не…
  2. Jul 6, 2026Последнее время на работе часто приходится работать с apache flink и даже что-то писать на…
  3. Jun 4, 2026Немножко про молекула тесты... У нас принято использовать в переменных lookup плагин для д…
  4. May 20, 2026Очередной небольшой проект. Веб-приложение, которое агрегирует через стандартный механиз g…
  5. May 15, 2026Включаем профилирование в ansible Профилирование, это вывод даты, времени запуска и итогов…
  6. Apr 17, 2026Так выглядит общий dashbord работы с инцидентами.
Threads Profile ViewerView any public Threads profile without an account.Open ThreadLook →Writing with AI? Make it sound human.Metric37 rewrites AI drafts so they read naturally. Free AI detector, 1,500 words free.Try Metric37 →