快速代理的只读配置
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 设置为 可使用来自生成器的 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 |