Modificación de parámetros de Kafka
Escenario
Sus instancias, temas y consumidores de Kafka vienen con los parámetros de configuración predeterminados. Puede modificar parámetros comunes en la consola. Para obtener más información sobre los parámetros que no aparecen en la consola, consulte el sitio web oficial de Kafka.
Los parámetros de las instancias v1.1.0 son todos parámetros estáticos. Las instancias v2.3.0/2.7 tienen parámetros dinámicos y estáticos.
- Parámetros dinámicos: la modificación de los parámetros dinámicos no reiniciará la instancia.
- Parámetros estáticos: después de modificar los parámetros estáticos, debe reiniciar manualmente la instancia.
Los parámetros de configuración de algunas instancias antiguas no se pueden modificar. Compruebe si los parámetros de instancia se pueden modificar en la consola.
Prerrequisitos:
Puede modificar los parámetros de configuración de una instancia de Kafka solo cuando la instancia está en el estado Running.
Procedimiento
- Inicie sesión en la consola de gestión.
- Haga clic en
en la esquina superior izquierda para seleccionar la región.
Seleccione la misma región que su servicio de aplicación.
- Haga clic en
y elija Application > Distributed Message Service (for Kafka) para abrir la consola de DMS for Kafka. - Haga clic en la instancia de Kafka deseada para ver sus detalles.
- En la página de la ficha Parameters, haga clic en Edit en la fila que contiene el parámetro que se va a modificar. Tabla 1 describe los parámetros de las instancias v1.1.0. Tabla 2 y Tabla 3 describir los parámetros de las instancias v2.3.0/2.7.
Tabla 1 Parámetros estáticos (instancias v1.1.0) Parámetro
Descripción
Rango de valores
Valor predeterminado
min.insync.replicas
Si un productor establece el parámetro acks en all (o -1), el parámetro min.insync.replicas especifica el número mínimo de réplicas en el conjunto de réplicas in-sync (ISR).
Si no se cumple este mínimo, el productor levantará una excepción y no se podrán crear mensajes.
1–3
1
message.max.bytes
Longitud máxima de un solo mensaje, en bytes.
0–10,485,760
10,485,760
unclean.leader.election.enable
Indica si se permite que las réplicas que no están en el conjunto ISR se eligen como directriz.
Si este parámetro se establece en true, los datos pueden perderse.
true o false
true
connections.max.idle.ms
Tiempo de espera de la conexión inactiva. Las conexiones que estén inactivas durante la duración especificada por este parámetro se cerrarán.
5000–600,000
600,000
log.retention.hours
Duración (en horas) para conservar un archivo de registro.
Este parámetro solo tiene efecto para los temas que no tienen tiempo de caducidad configurado. Si hay tiempo de caducidad configurado para los temas, se anula este parámetro.
1–168
72
max.connections.per.ip
Número máximo de conexiones permitidas desde cada dirección IP. Las solicitudes de nuevas conexiones se rechazarán una vez que se alcance el límite.
100–20,000
1000
group.max.session.timeout.ms
Tiempo máximo de espera de sesión para los consumidores. Un tiempo de espera más largo da a los consumidores más tiempo para procesar los mensajes entre los latidos del corazón, pero resulta en un tiempo más largo para detectar fallas.
6000–1,800,000
1,800,000
default.replication.factor
Número predeterminado de réplicas configuradas para un tema creado automáticamente.
1–3
3
num.partitions
Número predeterminado de particiones configuradas para un tema creado automáticamente.
1–100
3
group.min.session.timeout.ms
El tiempo de espera mínimo de la sesión para los consumidores. Un tiempo de espera más corto permite una detección de fallos más rápida, pero resulta en un ritmo cardíaco más frecuente del consumidor, lo que puede abrumar los recursos de los corredores.
6000–300,000
6000
Tabla 2 Parámetros dinámicos (instancias v2.3.0/2.7) Parámetro
Descripción
Rango de valores
Valor predeterminado
min.insync.replicas
Si un productor establece el parámetro acks en all (o -1), el parámetro min.insync.replicas especifica el número mínimo de réplicas en el conjunto de réplicas in-sync (ISR).
Si no se cumple este mínimo, el productor levantará una excepción y no se podrán crear mensajes.
1–3
1
message.max.bytes
Longitud máxima de un solo mensaje, en bytes.
0–10,485,760
10485760
unclean.leader.election.enable
Indica si se permite que las réplicas que no están en el conjunto ISR se eligen como directriz.
Si este parámetro se establece en true, los datos pueden perderse.
true o false
true
Tabla 3 Parámetros estáticos (instancias v2.3.0/2.7) Parámetro
Descripción
Rango de valores
Valor predeterminado
connections.max.idle.ms
Tiempo de espera de la conexión inactiva. Las conexiones que estén inactivas durante la duración especificada por este parámetro se cerrarán.
5000–600,000
600,000
log.retention.hours
Duración (en horas) para conservar un archivo de registro.
Este parámetro solo tiene efecto para los temas que no tienen tiempo de caducidad configurado. Si hay tiempo de caducidad configurado para los temas, se anula este parámetro.
1–168
72
max.connections.per.ip
Número máximo de conexiones permitidas desde cada dirección IP. Las solicitudes de nuevas conexiones se rechazarán una vez que se alcance el límite.
100–20,000
1000
group.max.session.timeout.ms
Tiempo máximo de espera de sesión para los consumidores. Un tiempo de espera más largo da a los consumidores más tiempo para procesar los mensajes entre los latidos del corazón, pero resulta en un tiempo más largo para detectar fallas.
6000–1,800,000
1,800,000
default.replication.factor
El número predeterminado de réplicas configuradas para un tema creado automáticamente.
1–3
3
num.partitions
Número predeterminado de particiones configuradas para un tema creado automáticamente.
1–100
3
group.min.session.timeout.ms
El tiempo de espera mínimo de la sesión para los consumidores. Un tiempo de espera más corto permite una detección de fallos más rápida, pero resulta en un ritmo cardíaco más frecuente del consumidor, lo que puede abrumar los recursos de los corredores.
6000–300,000
6000
Para modificar varios parámetros a la vez, seleccione los parámetros y haga clic en Modify encima de la lista de parámetros.
- Haga clic en Save.
La modificación de los parámetros dinámicos no reiniciará la instancia. Reinicie manualmente la instancia después de modificar los parámetros estáticos.
