Versäumte den Kraft -Controller in K8s nicht zu starten ⇐ Java

[Anonymous]

Wir probieren Zookeeper manuell mit der Kafka Kraft -Migration in unserer K8s -Umgebung aus. Dafür besteht der erste Schritt darin, Kraft -Controller im Migrationsmodus bereitzustellen. Wir haben ConfigMaps verwendet, um die Controller.Properties -Konfiguration während des Serverstarts bereitzustellen.

Code: Select all

# {% raw %}
---
apiVersion: v1
kind: ConfigMap
metadata:
name: kraft-controller-config
namespace: cgbu-ums-dev
data:
controller.properties: |
zookeeper.metadata.migration.enable=true
zookeeper.connect=zookeeper:2181
process.roles=controller
node.id=0
controller.quorum.voters=0@kraft-controller-0.kraft-controller:9092
#controller.quorum.bootstrap.servers=kraft-controller:9092
listeners=CONTROLLER://kraft-controller-0:9092
advertised.listeners=CONTROLLER://kraft-controller-0:9092
controller.listener.names=CONTROLLER
num.network.threads=3
num.io.threads=8
socket.send.buffer.bytes=102400
socket.receive.buffer.bytes=102400
socket.request.max.bytes=104857600
log.dirs=/var/lib/kafka/data/kraft-controller-0
num.partitions=1
num.recovery.threads.per.data.dir=1
offsets.topic.replication.factor=1
transaction.state.log.replication.factor=1
transaction.state.log.min.isr=1
share.coordinator.state.topic.replication.factor=1
share.coordinator.state.topic.min.isr=1
log.retention.hours=168
log.segment.bytes=1073741824
log.retention.check.interval.ms=300000
# {% endraw %}
< /code>
auf Serverstart Ich erhalte diesen folgenden Fehler: < /p>
[2025-05-06 05:25:13,768] ERROR Encountered fatal fault: exception while completing controller activation (org.apache.kafka.server.fault.ProcessTerminatingFaultHandler)
java.lang.RuntimeException: Should not have ZK migrations enabled on a cluster that was created in KRaft mode.
at org.apache.kafka.controller.ActivationRecordsGenerator.recordsForNonEmptyLog(ActivationRecordsGenerator.java:168)
at org.apache.kafka.controller.ActivationRecordsGenerator.generate(ActivationRecordsGenerator.java:234)
at org.apache.kafka.controller.QuorumController$CompleteActivationEvent.generateRecordsAndResult(QuorumController.java:1243)
at org.apache.kafka.controller.QuorumController$ControllerWriteEvent.run(QuorumController.java:791)
at org.apache.kafka.queue.KafkaEventQueue$EventContext.run(KafkaEventQueue.java:132)
at org.apache.kafka.queue.KafkaEventQueue$EventHandler.handleEvents(KafkaEventQueue.java:215)
at org.apache.kafka.queue.KafkaEventQueue$EventHandler.run(KafkaEventQueue.java:186)
at java.base/java.lang.Thread.run(Thread.java:842)

Anfangs habe ich den Kraft -Controller zuerst mit Migration gestartet - sie begann erfolgreich, dann habe ich die configMap geändert und Migrationseigenschaften hinzugefügt und Kubectl rolout restart geführt. Beim Neustart bekam ich den gleichen Fehler, den ich glaube, weil der Pod im reinen Kraftmodus begann, aber als später gesagt wurde, dass sie Migration durchführen soll, kann es ein Problem in der Formatierung von logariten.dir -Eigenschaften geben, damit sie fehlgeschlagen ist. Benötigen Sie Hilfe, um herauszufinden, warum dies passiert ist und wie ich es beheben kann.