Utilisation de l'API Kafka d'administration du client Java

Si vous utilisez un client Kafka version 0.11 ou ultérieure, ou Kafka Streams version 0.10.2.0 ou ultérieure, vous pouvez utiliser des API pour créer et supprimer des rubriques. Nous avons mis des restrictions sur les paramètres qui sont autorisés lorsque vous créez des rubriques. Consultez les paramètres suivants que vous pouvez modifier.

cleanup.policy

Défini sur delete (par défaut), compact ou delete,compact.

retention.ms

La durée de conservation par défaut est de 24 heures. La durée minimale est d'une heure et la durée maximale de 30 jours. Spécifiez cette valeur comme un nombre d'heures.

Dans le plan Enterprise, vous pouvez définir la conservation sur n'importe quelle valeur.

retention.bytes

Taille maximale que peut atteindre une partition (constituée de segments de journaux) avant suppression des anciens segments de journaux afin de libérer de l'espace.

Plan Enterprise uniquement. Définissez une valeur supérieure à 10 Mo.

segment.bytes

Taille du fichier de segments du journal.

Plan Enterprise uniquement. Toute valeur supérieure à 100 Mo.

segment.index.bytes

La taille de l'index qui met en correspondance des décalages et des positions de fichier.

Plan Enterprise uniquement. Définissez une valeur comprise entre 100 ko et 1 Go.

segment.ms

Période à l'issue de laquelle Kafka force le journal à être réutilisé même si le fichier de segment n'est pas saturé.

Plan Enterprise uniquement. Définis sur n'importe quelle valeur comprise entre 5 minutes et 30 jours.