Configuraciones de solo lectura para agentes Express - Transmisión administrada de Amazon para Apache Kafka

Configuraciones de solo lectura para agentes Express

Amazon MSK establece los valores de estas configuraciones y los protege frente a cambios que podrían afectar la disponibilidad del clúster. Estos valores pueden variar en función de la versión de Apache Kafka que se ejecute en el clúster, por lo que recuerde comprobar los valores correspondientes al clúster específico.

La siguiente tabla enumera las configuraciones de solo lectura para los agentes Express.

Propiedad Descripción Valor de agente Express
broker.id El identificador del agente para este servidor. 1,2,3...
broker.rack Rack del agente. Se utiliza en la asignación de réplicas con reconocimiento de rack para tolerancia a errores. Ejemplos: “RACK1”, “us-east-1d” ID de la zona de disponibilidad (AZ) o ID de la subred

default.replication.factor

Factores de replicación predeterminados para todos los temas

3

fetch.max.bytes El número máximo de bytes que se devolverán para una solicitud de obtención. Valor predeterminado de Apache Kafka
group.max.size El número máximo de consumidores que puede admitir un único grupo de consumidores. Valor predeterminado de Apache Kafka
inter.broker.listener.name Nombre del oyente utilizado para la comunicación entre agentes. REPLICATION_SECURE o REPLICATION
inter.broker.protocol.version Especifica qué versión del protocolo de comunicación entre agentes se utiliza. Valor predeterminado de Apache Kafka
oyentes Lista de oyentes: lista separada por comas de URI en los que se escuchará y los nombres de los oyentes. Puede configurar la propiedad advertised.listeners property, pero no la propiedad listeners. Generado por MSK
log.message.format.version Especifique la versión del formato de mensajes que el agente utilizará para anexar mensajes a los registros. Valor predeterminado de Apache Kafka

min.insync.replicas

Cuando un productor establece acks en all (o -1), el valor en min.insync.replicas especifica el número mínimo de réplicas que deben confirmar una escritura para que esta se considere exitosa. Si no se puede cumplir este mínimo, el productor genera una excepción (ya sea NotEnoughReplicas o NotEnoughReplicasAfterAppend).

Puede usar el valor de acks desde el productor para aplicar garantías de durabilidad más estrictas. Para ello, establezca acks en “todos”. Esto garantiza que el productor emita una excepción si la mayoría de las réplicas no reciben una escritura.

2

num.io.threads Número de subprocesos que el servidor usa para producir solicitudes, que pueden incluir E/S de disco: (m7g.large, 8), (m7g.xlarge, 8), (m7g.2xlarge, 16), (m7g.4xlarge, 32), (m7g.8xlarge, 64), (m7g.12xlarge, 96), (m7g.16xlarge, 128) Según el tipo de la instancia =Math.max(8, 2 * vCPUs)
num.network.threads Número de subprocesos que el servidor usa para recibir solicitudes desde la red y enviar respuestas a la red: (m7g.large, 8), (m7g.xlarge, 8), (m7g.2xlarge, 8), (m7g.4xlarge, 16), (m7g.8xlarge, 32), (m7g.12xlarge, 48), (m7g.16xlarge, 64) Según el tipo de la instancia =Math.max(8, vCPUs)
replica.fetch.response.max.bytes El número máximo de bytes previsto para la respuesta de recuperación completa. Los registros se recuperan en lotes y, si el primer lote de registro de la primera partición que no está vacía de la recuperación es superior a este valor, el lote de registro se devolverá para asegurar que se lleva a cabo el progreso. Esto no es un valor máximo absoluto. Las propiedades message.max.bytes (configuración del agente) o max.message.bytes (configuración del tema) especifican el tamaño máximo del lote de registros que acepta el agente. Valor predeterminado de Apache Kafka
request.timeout.ms Esta configuración controla el tiempo máximo que el cliente esperará la respuesta de una solicitud. Si la respuesta no se recibe antes de que expire el tiempo de espera, el cliente reenviará la solicitud si es necesario o la marcará como fallida si se agotan los reintentos. Valor predeterminado de Apache Kafka
transaction.state.log.min.isr Se sobrescribe la configuración min.insync.replicas para el tema de transacciones. 2
transaction.state.log.replication.factor El factor de replicación del tema de transacción. Valor predeterminado de Apache Kafka

unclean.leader.election.enable

Permite que réplicas que no estén en el conjunto ISR actúen como líder como último recurso, aunque esto puede provocar pérdida de datos.

FALSO