Ich habe den Befehl zum Löschen eines Themas ausgegeben:
./bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic vip_ips_alerts
Es schien eine glückliche Antwort zu geben:
[2014-05-31 20:58:10,112] INFO zookeeper state changed (SyncConnected) (org.I0Itec.zkclient.ZkClient)
Topic "vip_ips_alerts" queued for deletion.
Aber jetzt, 10 Minuten später, erscheint das Thema immer noch im --list
Befehl:
./bin/kafka-topics.sh --zookeeper localhost:2181 --list
vip_ips_alerts - marked for deletion
Was bedeutet das? Wann wird das Thema wirklich gelöscht? Wie beschleunige ich diesen Prozess?
apache-kafka
StephenBoesch
quelle
quelle
In meinem Fall, in dem ich Kafka 8.2.2 verwende, musste ich Einträge aus den folgenden manuell löschen:
Loggen Sie sich bei zookeeper ein und -
quelle
Du kannst es schaffen.
quelle
Ich stand vor dem gleichen Problem und verbrachte ein paar Tage damit, mich mit dem Problem zu identifizieren. Ich habe den Befehl zum Löschen der Themen ausgelöst. Die Themen wurden jedoch zum Löschen markiert, aber nicht gelöscht.
Keiner half. Ich musste mich endlich bei zooker anmelden
Bitte denken Sie daran, kafka danach neu zu starten. Hoffe das löst dein Problem.
quelle
Die richtige Antwort lautet tatsächlich wie folgt. HOT von der Gruppen-E-Mail-Verteilerliste des Kafka-Benutzers:
quelle
Mein Problem war etwas Ähnliches. Ich habe ein Thema gelöscht und es gab mir die gleiche Nachricht, als ich alle Themen auflistete.
Ich habe den Tierpfleger und den Makler gestürzt. setze die delete.topic.enable = true in meiner Broker-Konfigurationsdatei gestartet zookeeper und der Boker
Das Thema war weg ... dank Jacek Laskowski
quelle
Für die Kafka-Version reicht
0.10.0.0
es aus, das Löschen des Themas zu aktivieren, indem Sie Folgendes festlegen :Das Thema wird innerhalb weniger Augenblicke gelöscht
Sie können mit dem folgenden Befehl bestätigen, dass es nicht mehr vorhanden ist:
quelle
Überprüfen Sie den Status des Themas bei zookeeper
Das Setzen von delete.topic.enable = true in server.properties funktionierte ebenfalls nicht.
Lösung: Überprüfen Sie den Speicherort des zookeeper-Datenverzeichnisses in der Datei zookeeper.properties. es war dataDir = / tmp / zookeeper .
Das Problem wurde behoben, nachdem "dataDir" an einen neuen Speicherort aktualisiert wurde.
quelle
Wir hatten dieses Problem beim Löschen von Themen. Die Themen wurden erstellt, als delete.topic.enable = true nicht festgelegt wurde. Wir haben das in config festgelegt und kafka neu gestartet, um die neue Konfiguration anzuwenden. Löschte die Themen und sah das "zum Löschen markiert". Wir haben dann kafka wieder neu gestartet. Nach 40 Minuten wurden jedoch alle Themen gelöscht (9 Themen mit insgesamt Tausenden von Partitionen). Die Themen mit einer höheren Anzahl von Partitionen schienen länger zu dauern, was zunächst den Eindruck erweckte, dass nichts passierte.
quelle
Das Löschen erfolgte für mich fast sofort (v 0.9). Ich glaube, dass es für Sie genauso sein sollte.
Nach dem Markieren wird das Löschen auf dem Kafka-Knoten ausgelöst, der der Themenpartitionsleiter ist. Beachten Sie, dass der Themenpartitionsleiter korrekt konfiguriert sein muss (in Bezug auf Listener), da er sonst nicht die Anweisung zum Löschen der Protokolle erhält.
Ich hatte meine Themen zum Löschen markiert in diesem Zustand, bis ich meine Servereigenschaften korrigierte und den jeweiligen Knoten neu startete.
quelle
Sobald das Thema in Kafka zum Löschen markiert ist, wird es nach 60000 Millisekunden endgültig entfernt.
Überprüfen Sie die Eigenschaft log.segment.delete.delay.ms.
Die Dokumentation sagt:
quelle