Utilización de la API cliente Kafka Java de administración

Si utiliza un cliente Kafka versión 0.11 o posterior, o Kafka Streams versión 0.10.2.0 o posterior, puede utilizar las API para crear y suprimir temas. Ponemos algunas restricciones en los valores que se permiten al crear temas. Consulte los valores siguientes que puede modificar.

cleanup.policy

Establézcalo en delete (valor predeterminado) compact o delete,compact.

retention.ms

El período de retención predeterminado es de 24 horas. El valor mínimo es de 1 hora y el máximo de 30 días. Especifique este valor como múltiplo de horas.

En el plan Empresa, puede establecer la retención en cualquier valor.

retention.bytes

El tamaño máximo que puede alcanzar una partición (que consiste en segmentos de registro) hasta que se descartan segmentos de registro antiguos para liberar espacio.

Sólo plan Enterprise. Se establece en cualquier valor superior a 10 MB.

segment.bytes

El tamaño del archivo de segmento para el registro.

Sólo plan Enterprise. Defina cualquier valor mayor que 100 kB.

segment.index.bytes

El tamaño del índice que correlaciona desplazamientos con posiciones de archivo.

Sólo plan Enterprise. Se establece en cualquier valor entre 100 kB y 1 GB.

segment.ms

El periodo tras el cual Kafka fuerza la retrotracción del registro aunque el archivo de segmento no esté lleno.

Sólo plan Enterprise. Establézcalo en cualquier valor entre 5 minutos y 30 días.