Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.
Configurazioni di sola lettura di Express Brokers
Amazon MSK imposta i valori per queste configurazioni e le protegge dalle modifiche che potrebbero influire sulla disponibilità del cluster. Questi valori possono cambiare a seconda della versione di Apache Kafka in esecuzione sul cluster, quindi ricordati di controllare i valori del tuo cluster specifico.
La tabella seguente elenca le configurazioni di sola lettura per i broker Express.
| Proprietà | Description | Valore di Express Broker |
|---|---|---|
| broker.id | L'id del broker per questo server. | 1,2,3... |
| broker.rack | Rack del broker. Verrà utilizzato nell'assegnazione della replica in modalità rack aware per la tolleranza ai guasti. Esempi: `RACK1`, `us-east-1d` | ID AZ o ID di sottorete |
|
default.replication.factor |
Fattori di replica predefiniti per tutti gli argomenti. |
3 |
| fetch.max.bytes | Il numero massimo di byte che restituiremo per una richiesta di recupero. | Impostazione predefinita di Apache Kafka |
| group.max.size | Il numero massimo di consumatori che un singolo gruppo di consumatori può ospitare. | Impostazione predefinita di Apache Kafka |
| inter.broker.listener.name | Nome del listener utilizzato per la comunicazione tra broker. | REPLICATION_SECURE o REPLICATION |
| inter.broker.protocol. version | Specifica quale versione del protocollo inter-broker viene utilizzata. | Apache Kafka (impostazione predefinita) |
| listener | Listener List: Comma-separated elenco degli URI su cui ascolteremo e i nomi degli ascoltatori. È possibile impostare la proprietàadvertised.listeners property, ma non la proprietà. listeners |
MSK-generated |
| log.message.format.version | Specifica la versione del formato del messaggio che il broker utilizzerà per aggiungere messaggi ai log. | Impostazione predefinita di Apache Kafka |
min.insync.replicas |
Quando un produttore imposta ack su Puoi utilizzare il valore delle confezioni fornite dal tuo produttore per applicare maggiori garanzie di durata. Impostando i pacchetti su «tutti». Ciò garantisce che il produttore generi un'eccezione se la maggior parte delle repliche non riceve una scrittura. |
2 |
| num.io.thread | Numero di thread utilizzati dal server per produrre richieste, che possono includere il disco I/O. (m7g.large, 8), (m7g.xlarge, 8), (m7g.2xlarge, 16), (m7g.4xlarge, 32), (m7g.8xlarge, 64), (m7g.12xlarge, 96), (m7g.16xlarge, 128) | In base al tipo di istanza. = Math.max (8, 2 * vCPU) |
| num.network.threads | Numero di thread utilizzati dal server per ricevere richieste dalla rete e inviare risposte alla rete. (m7g.large, 8), (m7g.xlarge, 8), (m7g.2xlarge, 8), (m7g.4xlarge, 16), (m7g.8xlarge, 32), (m7g.12xlarge, 48), (m7g.16xlarge, 64) | In base al tipo di istanza. = Math.max (8, vCPU) |
| replica.fetch.response.max.bytes | Il numero massimo di byte previsto per l'intera risposta di recupero. I record vengono recuperati in batch. Se il primo batch di record nella prima partizione non vuota del recupero è più grande di questo valore, il batch di record verrà comunque restituito per garantire l'avanzamento. Questo non è un massimo assoluto. Le proprietà message.max.bytes (broker config) o max.message.bytes (topic config) specificano la dimensione massima del batch di record accettata dal broker. |
Impostazione predefinita di Apache Kafka |
| richiesta.timeout.ms | La configurazione controlla il tempo massimo di attesa del client per la risposta a una richiesta. Se la risposta non viene ricevuta prima dello scadere del timeout, il client invierà nuovamente la richiesta se necessario o fallirà la richiesta se i tentativi saranno esauriti. | Impostazione predefinita di Apache Kafka |
| transaction.state.log.min.isr | min.insync.replicasConfigurazione sostituita per l'argomento della transazione. |
2 |
| transaction.state.log.replication.factor | Il fattore di replica per l'argomento di transazione. | Impostazione predefinita di Apache Kafka |
unclean.leader.election.enable |
Consente alle repliche non incluse nell'ISR impostato di fungere da leader come ultima risorsa, anche se ciò potrebbe comportare la perdita di dati. |
FALSE |
