Ich versuche, die Retention.ms -Eigenschaft für ein vorhandenes Thema zu ändern, aber nach meiner Analyse löscht es alle vorhandenen Daten innerhalb des Themas.Alter retention.ms Eigenschaft für kafka Thema löscht die alten Daten
Szenarios: - Anfangs ist mein Thema Name "topic1" mit Aufbewahrung als 5 Mins und es enthält einige Daten.
Use Case 1 - Ändern Sie die Beibehaltung einer höheren Periode Dann ändere ich den retention.ms Wert auf 8 Minuten mit den folgenden Befehl: -
bin/kafka-topics.sh --alter --zookeeper localhost:2181
--topic topic1 --config retention.ms=8
Aber es löscht alle meine alten Daten aus, dass Thema. Danach habe ich noch mehr Daten in dieses Thema gepusht.
Use Case 2 - Ändern Sie die Retention auf eine niedrigere Zeit Dann wechsle ich den retention.ms Wert auf 3 Minuten mit den folgenden Befehl: -
bin/kafka-topics.sh --alter --zookeeper localhost:2181
--topic topic1 --config retention.ms=3
Es ist auch die vorherigen Daten löscht, dass sich von der Thema.
Könnte jemand bitte mir das genaue Verhalten für das gleiche sagen.
Alle Tipps geschätzt!
Ja, das ist in Ordnung. Aber ich brauche Klarheit darüber, warum die Daten im Thema nach der Aktualisierung von retention.ms gelöscht werden. –
Es löscht Daten, weil Ihre Daten älter sind als Ihre Aufbewahrungsfrist und so funktioniert die Aufbewahrung. – avr
Auch wenn es nicht älter als die Aufbewahrungsfrist ist, löscht es die Daten. Ich habe diese kafka Stand-alone-Modus-Befehlszeile ausprobiert. –