快速代理的只读配置 - Amazon Managed Streaming for Apache Kafka

本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。

快速代理的只读配置

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

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

属性 说明 快速代理的值
broker.id 该服务器的代理 ID。 1,2,3...
broker.rack 代理的机架。这将用于机架感知复制分配,以确保具有容错能力。示例:`、`us-east-1dRACK1` 可用区 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

当生成器将 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 * v) CPUs
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, v) CPUs
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