Utilizzo dell'API client Java Kafka di amministrazione

Se utilizzi un client Kafka versione 0.11 o successiva o Kafka Streams versione 0.10.2.0 o successiva, puoi utilizzare le API per creare ed eliminare gli argomenti. Abbiamo messo alcune restrizioni sulle impostazioni che sono consentite quando si creano argomenti. Vedere le seguenti impostazioni che è possibile modificare.

cleanup.policy

Impostare su delete (predefinito), compact o delete,compact.

retention.ms

Il periodo di conservazione predefinito è 24 ore. Il minimo è 1 ora e il massimo è 30 giorni. Specifica questo valore come multipli di ore.

Nel piano Enterprise, puoi impostare la conservazione su qualsiasi valore.

retention.bytes

La dimensione massima di una partizione (che consiste in segmenti di log) può crescere fino a prima che eliminiamo i segmenti di log obsoleti per liberare spazio.

Solo piano Enterprise. Impostare su un valore maggiore di 10 MB.

segment.bytes

La dimensione del file di segmenti per il log.

Solo piano Enterprise. Imposta su un qualsiasi valore maggiore di 100 kB.

segment.index.bytes

La dimensione dell'indice che associa gli offset alle posizioni file.

Solo piano Enterprise. Impostare su un valore compreso tra 100 kB e 1 GB.

segment.ms

Il periodo dopo il quale Kafka forza il rollio del log anche se il file di segmento non è pieno.

Solo piano Enterprise. Impostare su un valore compreso tra 5 minuti e 30 giorni.