Express 代理程式唯讀組態 - Amazon Managed Streaming for Apache Kafka

本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。

Express 代理程式唯讀組態

Amazon MSK會設定這些組態的值,並保護這些組態免於變更而影響叢集的可用性。這些值可能會根據叢集上執行的 Apache Kafka 版本而有所不同,因此請記得檢查特定叢集中的值。請見下方範例。

Express 代理程式唯讀組態
屬性 描述 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 設定為 all(或 -1) 時, 中的值會min.insync.replicas指定必須確認寫入才能視為成功的複本數目下限。如果無法達到此最小值,生產者會提出例外狀況 ( NotEnoughReplicasNotEnoughReplicasAfterAppend)。

您可以使用生產者提供的 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