快递经纪人只读配置 - 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...
经纪人.rack 经纪人的架子。这将用于机架感知复制分配以实现容错。示例:`、`us-east-1dRACK1` 可用区 ID 或子网 ID

default.replication.factor

所有主题的默认复制因子。

3

读取.max.bytes 我们将为读取请求返回的最大字节数。 Apache Kafka 默认
群组最大大小 单个消费者组可以容纳的最大消费者数量。 Apache Kafka 默认
inter.broker.listener.name 用于代理之间通信的监听器的名称。 复制_安全还是复制
inter.broker.protocol. 指定使用哪个版本的经纪人间协议。 Apache Kafka 默认
听众们 监听器列表-以逗号分隔的 URIs 我们将要监听的列表和监听器名称。您可以设置属性advertised.listeners property,但不能设置listeners属性。 MSK 生成的
log.message.format.ver 指定代理将用于将消息附加到日志的消息格式版本。 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),(m7g.12xlarge,48),(m7g.16xlarge,64) 基于实例类型。=math.max (8, v) CPUs
replica.fetch.response.max.bytes 整个提取响应预期的最大字节数。记录是分批提取的,如果提取的第一个非空分区中的第一个记录批处理大于此值,则仍将返回该记录批处理以确保取得进展。这不是绝对最大值。message.max.bytes(经纪人配置)或max.message.bytes(主题配置)属性指定代理接受的最大记录批次大小。 Apache Kafka 默认
请求.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