文件名称:Topic级别配置-树莓派python编程指南
文件大小:3.8MB
文件格式:PDF
更新时间:2024-07-21 13:27:43
kafka官方文档 kafka kafka中文 kafka文档
3.2 Topic级别配置 与Topic相关的配置既包含服务器默认值,也包含可选的每个Topic覆盖值。 如果没有给出每个Topic的配置, 那么服务器默认值就会被使⽤。 通过提供⼀个或多个 --config 选项,可以在创建Topic时设置覆盖值。 本 示例使⽤⾃定义的Y⼤消息⼤⼩和刷新率创建了⼀个名为 my-topic 的topic: 也可以在使⽤alter con�gs命令稍后更改或设置覆盖值. 本示例重置my-topic的Y⼤消息的⼤⼩: 您可以执⾏如下操作来检查topic设置的覆盖值 您可以执⾏如下操作来删除⼀个覆盖值 以下是Topic级别配置。 “服务器默认属性”列是该属性的默认配置。 ⼀个Topic如果没有给出⼀个明确的覆盖 值,相应的服务器默认配置将会⽣效。 authorizer.class. name ⽤于认证授权的程序类 string "" 低 create.topic.poli cy.class.name ⽤于验证的创建topic策略类。 该类应该实现org.apache.kafka.server.policy.createtopicpolicy接 ⼝。 class null 低 listener.security. protocol.map 侦听器名称和安全协议之间的映射。必须定义为相同的安全协议可⽤于多个端⼝或IP。例如,即 使两者都需要ssl,内部和外部流量也可以分开。具体的说,⽤户可以定义名字为INTERNAL和 EXTERNAL的侦听器,这个属性为:internal:ssl,external:ssl。 如图所示,键和值由冒号分 隔,映射条⽬以逗号分隔。 每个监听者名字只能在映射表上出现⼀次。 通过向配置名称添加规 范化前缀(侦听器名称⼩写),可以为每个侦听器配置不同的安全性(ssl和sasl)设置。 例如, 为内部监听器设置不同的密钥仓库,将会设置名称为 “listener.name.internal.ssl.keystore.location”的配置。 如果没有设置侦听器名称的配置,配置将 回退到通⽤配置(即`ssl.keystore.location`)。 string PLAINTEXT:PLA INTEXT,SSL:SSL, SASL_PLAINTEX T:SASL_PLAINT EXT,SASL_SSL:S ASL_SSL 低 metric.reporters 度量报告的类列表,通过实现 MetricReporter 接⼝,允许插⼊新度量标准类。JmxReporter 包含注册JVM统计。 list "" 低 metrics.num.sa mples 维持计算度量的样本数 int 2 [1,...] 低 metrics.recordin g.level 指标的Y⾼记录级别 string INFO 低 metrics.sample. window.ms 计算度量样本的时间窗⼝ long 30000 [1,...] 低 quota.window.n um 在内存中保留客户端限额的样本数 int 11 [1,...] 低 quota.window.si ze.seconds 每个客户端限额的样本时间跨度 int 1 [1,...] 低 replication.quota .window.num 在内存中保留副本限额的样本数 int 11 [1,...] 低 replication.quota .window.size.se conds 每个副本限额样本数的时间跨度 int 1 [1,...] 低 ssl.endpoint.ide nti�cation.algori thm 端点身份标识算法,使⽤服务器证书验证服务器主机名 string null 低 ssl.secure.rando m.implementati on ⽤于SSL加密操作的SecureRandom PRNG实现 string null 低 transaction.abor t.timed.out.trans action.cleanup.i nterval.ms 回滚已超时的事务的时间间隔 int 60000 [1,...] 低 transaction.rem ove.expired.tran saction.cleanup. interval.ms 删除由于transactional.id.expiration.ms传递过程⽽过期的事务的时间间隔 int 3600000 [1,...] low zookeeper.sync.t ime.ms ZK follower同步可落后leader多久/td> int 2000 低 名称 描述 类型 默认值 有效值 服务器默认属性 重要性 cleanup.policy 该配置项可以是 "delete" 或 "compact"。 它指定在旧⽇志段上使⽤的保留策 略。 默认策略 ("delete") 将在达到保留时间或⼤⼩限制时丢弃旧段。 list delete [compact, delete] log.cleanup.poli cy medium 1 2 > bin/kafka-topics.sh --zookeeper localhost:2181 --create --topic my-topic --partitions 1 --replication-factor 1 --config max.message.bytes=64000 --config flush.messages=1 1 2 > bin/kafka-configs.sh --zookeeper localhost:2181 --entity-type topics --entity-name my-topic --alter --add-config max.message.bytes=128000 1 > bin/kafka-configs.sh --zookeeper localhost:2181 --entity-type topics --entity-name my-topic --describe 1 > bin/kafka-configs.sh --zookeeper localhost:2181 --entity-type topics --entity-name my-topic --alter --delete-config max.message.bytes 33