Ce face comanda kafka-topics.sh –delete
Comanda kafka-topics.sh --delete elimină înregistrarea topicului din metadatele clusterului Kafka și inițiază curățarea asincronă a directoarelor de log de pe toate nodurile de stocare.
Exemplu Concret: Ștergerea unui topic de test
kafka-topics.sh --bootstrap-server localhost:9092 \
--delete \
--topic test-stres-vechi
Comportament și cerințe de configurare
- Brokerii trebuie să aibă setarea
delete.topic.enable=trueînserver.properties(valoare implicită în versiunile moderne). - Dacă există producători sau consumatori activi conectați la topic în momentul rulării comenzii, aceștia vor primi excepții de tip
UnknownTopicOrPartitionException.
Întrebări & Exemple de Cod:
kafka-topics.sh –delete: Ștergerea Topicelor din ClusterAi o nelămurire despre utilizarea comenzii
kafka-topics.sh –delete: Ștergerea Topicelor din Clustersau ai descoperit un truc / fragment de cod util? Distribuie-l cu ceilalți programatori!Fii primul care pune o întrebare sau distribuie un fragment de cod / prompt!
Nu au fost adăugate încă întrebări sau exemple de cod pentru această pagină. Dacă ai întâlnit o problemă sau ai un snippet util, adaugă-l mai jos pentru a-i ajuta pe ceilalți.