Сообщения темы Кафки пропали после перезагрузки кластера

Question

У нас есть двухузловой кластер Kafka, работающий в Openshift.Мы создали тему с политикой хранения, установленной на 30 дней.Эта работа, как ожидается, включая перезапуски отдельных брокеров.Однако, когда кластер Kafka перезапускается путем уменьшения набора состояний Kafka до 0 реплик и масштабирования до 2 реплик, все сообщения в темах исчезают.

Перед перезапуском кластера:

/ usr / bin / kafka-run-class kafka.tools.GetOffsetShell --broker-list localhost: 29092 --topic platform.openshift.events --time-1 --offsets 1

platform.openshift.events: 0: 73387

После перезапуска кластера:

$ / usr / bin / kafka-run-class kafka.tools.GetOffsetShell --broker-list localhost: 29092 --topic platform.openshift.events --time -1 --offsets 1

platform.openshift.events: 0: 0

Isэто ожидаемое поведение?Мы используем подключенный том для хранения тем Kafka.

Answer 1

Я заметил, что kafka.properteis устанавливает log.dirs = / var / lib / kafka / data, а не / var / lib / kafka.После изменения точки монтирования тома с / var / lib / kafka на / var / lib / kafka / data проблема исчезла.