В настоящее время я сталкиваюсь с модулем kafka kubernetes в CrashLoopBackOff
kafka-prod-4 1/2 CrashLoopBackOff 2640 15d
из-за существующей здесь ошибки, я считаю
[ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Exiting because log truncation is not allowed for partition __consumer_offsets-5, current leader's latest offset 0 is less than replica's latest offset 4 (kafka.server.ReplicaFetcherThread)
Я начинаю искать partition __consumer_offsets-5, а также смещения реплик, чтобы попытаться изменить смещение, чтобы эта ошибка не появлялась, но у меня возникают проблемы с поиском partition __consumer_offsets-5 для изменения смещения.
kafka-run-class kafka.tools.GetOffsetShell --broker-list kafka-prod:9092 --topic sfoo-SfooEvent --time -1
sfoo-SfooEvent:0:472643
sfoo-SfooEvent:1:472390
sfoo-SfooEvent:2:170840
https://issues.apache.org/jira/browse/KAFKA-3410
https://github.com/Yolean/kubernetes-kafka/issues/98
Некоторые из журналов, которые я вижу здесь https://pastebin.com/hDQCefY7
Кто-нибудь видел решение этой ошибки? Нужно ли класть ядро в кластер и начинать заново?