【文件属性】：
文件名称：Topic级别配置-树莓派python编程指南
文件大小：3.8MB
文件格式：PDF
更新时间：2021-07-01 19:41:03
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