Implicit, Kafka șterge mesajele mai vechi de o anumită perioadă de timp (ex: 7 zile prin cleanup.policy=delete). În schimb, politica cleanup.policy=compact tratează topicul ca pe un tabel de bază de date (Key-Value Store): păstrează pentru totdeauna cea mai recentă valoare pentru fiecare cheie unică, eliminând duplicatele istorice.
Crearea unui topic compactat pentru starea conturilor de utilizatori
# Crearea topicului cu politică de compactare:
bin/kafka-topics.sh --bootstrap-server localhost:9092 \
--create --topic stari-utilizatori \
--partitions 6 \
--replication-factor 3 \
--config cleanup.policy=compact \
--config min.cleanable.dirty.ratio=0.5 \
--config segment.ms=86400000
# Ștergerea unei chei (Tombstone):
# Pentru a șterge definitiv o cheie dintr-un topic compactat,
# producătorul trimite un mesaj cu cheia respectivă și valoarea NULL!
Întrebări & Exemple de Cod:
Compactarea Topicelor în Kafka: Politica cleanup.policy=compactAi o nelămurire despre utilizarea comenzii
Compactarea Topicelor în Kafka: Politica cleanup.policy=compactsau 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.