快速代理的只读配置 - Amazon Managed Streaming for Apache Kafka
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅 中国的 Amazon Web Services 服务入门 (PDF)

快速代理的只读配置

Amazon MSK 会为这些配置设置值,并防止遭到更改,以免影响集群的可用性。这些值可能会根据集群上运行的 Apache Kafka 版本而变化,因此请记住检查特定集群的值。

下表列出了快速代理的只读配置。

属性 描述 快速代理的值
broker.id 该服务器的代理 ID。 1、2、3...
broker.rack 代理的机架。这将用于机架感知复制分配,以确保具有容错能力。示例:“RACK1”、“us-east-1d” 可用区 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 默认值
侦听器 侦听器列表:以逗号分隔列表,含有侦听的 URI 列表和侦听器名称。您可以设置 advertised.listeners property,但不能设置 listeners 属性。 MSK 生成
log.message.format.version 指定代理用于将消息追加到日志的消息格式版本。 Apache Kafka 默认值

min.insync.replicas

当生成器将 acks 设置为 all(或 -1)时,min.insync.replicas 中的值会指定为使写入被视为成功而必须确认写入的最小副本数。如果无法达到这一最小值,生成器将引发异常(NotEnoughReplicasNotEnoughReplicasAfterAppend)。

可使用来自生成器的 acks 值,强制执行更高的持久性保证。通过将 acks 设置为 “全部”。这可确保在大多数副本未收到写操作时,创建器将引发异常。

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 * vCPU)
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