Verwaltungs-API von Kafka-Java-Client verwenden

Wenn Sie einen Kafka-Client der Version 0.11 oder höher oder Kafka Streams Version 0.10.2.0 oder höher verwenden, können Sie APIs zum Erstellen und Löschen von Topics verwenden. Wir haben einige Einschränkungen für die Einstellungen, die zulässig sind, wenn Sie Themen erstellen. Sehen Sie sich die folgenden Einstellungen an, die Sie ändern können.

cleanup.policy

Wird auf delete (Standardwert), compact oder delete,compact gesetzt.

retention.ms

Der Standardaufbewahrungszeitraum ist 24 Stunden. Der Mindestwert ist 1 Stunde und der Höchstwert ist 30 Tage. Geben Sie den Wert in Stunden an.

Im Enterprise-Plan können Sie die Aufbewahrung auf einen beliebigen Wert setzen.

retention.bytes

Die maximale Größe, auf die eine Partition (die aus Protokollsegmenten besteht) anwachsen kann, bis alte Protokollsegmente gelöscht werden, um Speicherbereich freizugeben.

Nur Enterprise-Plan. Legen Sie einen Wert fest, der größer als 10 MB ist.

segment.bytes

Die Segmentdateigröße für das Protokoll.

Nur Enterprise-Plan. Auf einen beliebigen Wert größer als 100 kB festlegen.

segment.index.bytes

Die Größe des Index, der Offsets Dateipositionen zuordnet.

Nur Enterprise-Plan. Legen Sie einen beliebigen Wert zwischen 100 KB und 1 GB fest.

segment.ms

Der Zeitraum, nach dem Kafka das Rollieren des Protokolls erzwingt, auch wenn die Segmentdatei nicht voll ist.

Nur Enterprise-Plan. Legen Sie einen beliebigen Wert zwischen 5 Minuten und 30 Tagen fest.