Kafka políticas de retención

Suponga que tengo una configuración de Kafka de varios intermediarios (ejecutándose en el mismo host) con 3 intermediarios y 50 temas, cada uno de los cuales está configurado para tener 7 particiones y un factor de replicación de 3.

Tengo 50 GB de memoria para gastar en kafka y me aseguro de que los registros de Kafka nunca excedan esta cantidad de memoria, así que quiero configurar mi política de retención para evitar este escenario.

He configurado una política de limpieza de eliminación:

log.cleaner.enable=true
log.cleanup.policy=delete

y necesito configurar las siguientes propiedades para que los datos se eliminen semanalmente y nunca me quede sin memoria:

log.retention.hours
log.retention.bytes
log.segment.bytes
log.retention.check.interval.ms
log.roll.hours

Estos temas contienen datos transmitidos por tablas en una Base de datos que tienen un tamaño total de aproximadamente 10 GB (pero las inserciones, actualizaciones o eliminaciones se transmiten constantemente en estos temas).

¿Cómo debo configurar los parámetros antes mencionados para que los datos se eliminen cada 7 días y asegurarse de que los datos se puedan eliminar en una ventana más corta si es necesario para que no se quede sin memoria?

Respuestas a la pregunta(2)

Su respuesta a la pregunta