Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.
Configurations en lecture seule d'Express Brokers
Amazon MSK définit les valeurs de ces configurations et les protège contre tout changement susceptible d'affecter la disponibilité de votre cluster. Ces valeurs peuvent changer en fonction de la version d'Apache Kafka exécutée sur le cluster. N'oubliez donc pas de vérifier les valeurs de votre cluster spécifique.
Le tableau suivant répertorie les configurations en lecture seule pour les courtiers Express.
| Propriété | Description | Valeur d'Express Broker |
|---|---|---|
| Broker.id | L'identifiant du courtier pour ce serveur. | 1, 2, 3... |
| courtier. rack | Étagère du courtier. Cela sera utilisé pour l'attribution de réplication tenant compte des racks pour des raisons de tolérance aux pannes. Exemples : `RACK1`, `us-east-1d` | ID AZ ou ID de sous-réseau |
|
default.replication.factor |
Facteurs de réplication par défaut pour tous les sujets. |
3 |
| récupérer le nombre maximum d'octets | Le nombre maximum d'octets que nous retournerons pour une demande de récupération. | Apache Kafka par défaut |
| taille maximale du groupe | Le nombre maximum de consommateurs qu'un seul groupe de consommateurs peut accueillir. | Apache Kafka par défaut |
| inter.broker.listener.name | Nom de l'auditeur utilisé pour la communication entre les courtiers. | REPLICATION_SECURE ou REPLICATION |
| inter.broker.protocol.version | Spécifie la version du protocole inter-courtiers utilisée. | Apache Kafka par défaut |
| écouteurs | Liste des auditeurs : Comma-separated liste des URI sur lesquels nous écouterons et des noms des auditeurs. Vous pouvez définir la propriétéadvertised.listeners property, mais pas la listeners propriété. |
MSK-generated |
| log.message.format.version | Spécifiez la version du format de message que le courtier utilisera pour ajouter des messages aux journaux. | Apache Kafka par défaut |
min.insync.replicas |
Lorsqu'un producteur met acks sur Vous pouvez utiliser la valeur des acks fournie par votre producteur pour renforcer les garanties de durabilité. En remettant à « tout ». Cela garantit que le producteur déclenche une exception si la majorité des réplicas ne reçoivent pas d'écriture. |
2 |
| num.io.threads | Nombre de threads utilisés par le serveur pour générer des requêtes, y compris le disque I/O. (7 g. large, 8), (m7 g. x large, 8), (m7 g.2 x large, 16), (m7 g.4 x large, 32), (m7 g.8 x large, 64), (m7 g.12 x large, 96), (m7 g.16 x large, 128) | En fonction du type d'instance. = Math.max (8, 2 * processeurs virtuels) |
| num.network.threads | Nombre de threads que le serveur utilise pour recevoir des demandes du réseau et envoyer des réponses au réseau. (7 g. large, 8), (m7 g. x large, 8), (m7 g.2 x large, 8), (m7 g.4 x large, 16), (m7 g.8 x large, 32), (m7 g.12 x large, 48), (m7 g.16 x large, 64) | En fonction du type d'instance. = Math.max (8, processeurs virtuels) |
| replica.fetch.response.max.bytes | Nombre maximal d'octets attendu pour l'ensemble de la réponse de récupération. Les enregistrements sont récupérés par lots, et si le premier lot d'enregistrements de la première partition non vide de l'extraction est supérieur à cette valeur, le lot d'enregistrements sera toujours renvoyé pour assurer la progression. Ce n'est pas un maximum absolu. Les propriétés message.max.bytes (configuration du courtier) ou max.message.bytes (configuration du sujet) spécifient la taille de lot d'enregistrements maximale acceptée par le courtier. |
Apache Kafka par défaut |
| requête.timeout.ms | La configuration contrôle la durée maximale pendant laquelle le client attendra la réponse à une demande. Si la réponse n'est pas reçue avant l'expiration du délai imparti, le client renverra la demande si nécessaire ou échouera si les nouvelles tentatives sont épuisées. | Apache Kafka par défaut |
| transaction.state.log.min.isr | min.insync.replicasConfiguration remplacée pour le sujet de transaction. |
2 |
| transaction.state.log.replication.factor | Facteur de réplication de la rubrique de la transaction. | Apache Kafka par défaut |
unclean.leader.election.enable |
Permet aux répliques ne figurant pas dans le paramètre ISR de jouer le rôle de leader en dernier recours, même si cela peut entraîner une perte de données. |
FALSE |
