Gibt es eine Möglichkeit, alle Daten eines Themas oder das Thema vor jeder Ausführung zu löschen?
Gibt es eine Möglichkeit, alle Daten eines Themas oder das Thema vor jeder Ausführung zu löschen?
Kann ich die Datei KafkaConfig.scala ändern, um die zu ändern?logRetentionHours Eigentum? Gibt es eine Möglichkeit, die Nachrichten zu löschen, sobald der Verbraucher sie liest?
Ich verwende Produzenten, um die Daten von irgendwoher abzurufen und an ein bestimmtes Thema zu senden, wo ein Verbraucher sie konsumiert. Kann ich bei jedem Durchlauf alle Daten aus diesem Thema löschen? Ich möchte immer nur neue Daten im Thema haben. Gibt es eine Möglichkeit, das Thema irgendwie neu zu initialisieren?