Producer-Konfig in konfluent-kafka

Question

Ich konnte in der Dokumentation nicht finden, wie die Aufbewahrungszeit beim Erstellen eines Producers mit konfluent-kafka eingestellt wird.

Wenn ich nur 'Bootstrap-Server' angeben, ist die Standard-Aufbewahrungszeit 1 Tag. Ich würde das gern ändern können.

(Ich möchte dies in der Python-API nicht in der Befehlszeile.) Vielen Dank für Ihre Hilfe.

Answer 1

Die Verweildauer ist keine Eigenschaft des Herstellers. Die Standardverweilzeit wird in der Brokerkonfigurationsdatei server.properties und Eigenschaften wie log.retention.hours, z. /etc/kafka/server.properties ... abhängig von Ihrer Installation.

Sie können die Aufbewahrungszeit für eine Themenbasis über z.

$ <path-to-kafka>/bin/kafka-topics.sh --zookeeper <zookeeper-quorum> --alter --topic <topic-name> --config retention.ms=<your-desired-retention-in-ms> 

HTH ....