本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。
Express 代理程式唯讀組態
Amazon MSK會設定這些組態的值,並保護這些組態免於變更而影響叢集的可用性。這些值可能會根據叢集上執行的 Apache Kafka 版本而有所不同,因此請記得檢查特定叢集中的值。請見下方範例。
屬性 | 描述 | Express Broker 值 |
---|---|---|
broker.id | 此伺服器的代理程式 ID。 | 1、2、3... |
broker.rack | 代理程式的機架。這將用於容錯能力的機架感知複寫指派。範例:`RACK1`、`us-east-1d` | AZ ID 或子網路 ID |
default.replication.factor |
所有主題的預設複寫因素。 |
3 |
fetch.max.bytes | 針對擷取請求,我們將傳回的位元組數上限。 | Apache Kafka 預設 |
group.max.size | 單一取用者群組可以容納的取用者數量上限。 | Apache Kafka 預設 |
inter.broker.listener.name | 用於代理程式之間通訊的接聽程式名稱。 | REPLICATION_SECURE 或 REPLICATION |
inter.broker.protocol.version | 指定使用哪個版本的中介協定。 | Apache Kafka 預設 |
接聽程式 | 接聽程式清單 - 我們將URIs接聽的逗號分隔清單和接聽程式名稱。您可以設定 advertised.listeners property ,但不能設定 listeners 屬性。 |
MSK產生的 |
log.message.format.version | 指定代理程式用來將訊息附加至日誌的訊息格式版本。 | Apache Kafka 預設 |
min.insync.replicas |
當生產者將 ack 設定為 您可以使用生產者提供的 ack 值來強制執行更高的耐用性保證。將 ack 設定為「全部」。若多數複本未接收寫入,如此可確保生產者會引發例外狀況。 |
2 |
num.io.threads | 伺服器用來產生請求的執行緒數目,其中可能包括磁碟 I/O。(m7g.large, 8)、(m7g.xlarge, 8)、(m7g.2xlarge, 16)、(m7g.4xlarge, 32)、(m7g.8xlarge, 64)、(m7g.12xlarge, 96)、(m7g.16xlarge, 128) | 根據執行個體類型。=Math.max(8, 2 * vCPUs) |
num.network.threads | 伺服器用來接收來自網路請求並將回應傳送到網路的執行緒數目。(m7g.large, 8)、(m7g.xlarge, 8)、(m7g.2xlarge, 8)、(m7g.4xlarge, 16)、(m7g.8xlarge, 32)、(m7g.12xlarge, 48)、(m7g.16xlarge, 64) | 根據執行個體類型。=Math.max(8,vCPUs) |
replica.fetch.response.max.bytes | 整個擷取回應預期的位元組數量上限。記錄會分批次擷取,若擷取的第一個非空白分區的第一個記錄批次大於此值,則會傳回此記錄批次,確保進度。此非絕對數量上限。message.max.bytes (代理程式組態) 或 max.message.bytes (主題組態) 屬性會指定代理程式接受的記錄批次大小上限。 |
Apache Kafka 預設 |
request.timeout.ms | 組態控制用戶端等待請求回應的時間上限。如果在逾時之前未收到回應,用戶端將視需要重新傳送請求,或在重試耗盡時失敗請求。 | Apache Kafka 預設 |
transaction.state.log.min.isr | 交易主題的覆寫min.insync.replicas 組態。 |
2 |
transaction.state.log.replication.factor | 交易主題的複寫係數。 | Apache Kafka 預設 |
unclean.leader.election.enable |
允許 ISR 集合中沒有 的複本做為最後手段的領導者,即使這可能會導致資料遺失。 |
FALSE |