文件名称:移除节流阀-树莓派python编程指南
文件大小:3.8MB
文件格式:PDF
更新时间:2024-07-21 13:27:43
kafka官方文档 kafka kafka中文 kafka文档
(1) 移除节流阀 ⼀旦重新分配完成,应及时移除节流阀(通过运⾏kafka-reassign-partitions -verify)。 (2) 确保进展: 如果与传⼊写⼊速率相⽐阈值设置得太低,复制可能⽆法取得进展。这发⽣在: BytesInPerSec是监控 producer 写⼊每个 broker 的写⼊吞吐量的指标。 管理员可以在重新平衡期间使⽤以下指标监控复制是否正在取得进展: max(BytesInPerSec) > throttle kafka.server:type=FetcherLagMetrics,name=ConsumerLag,clientId=([-.\w]+),topic= 1 2 leader.replication.throttled.replicas follower.replication.throttled.replicas 1 2 3 > bin/kafka-configs.sh --describe --zookeeper localhost:2181 --entity-type brokers Configs for brokers '2' are leader.replication.throttled.rate=700000000,follower.replication.throttled.rate=700000000 Configs for brokers '1' are leader.replication.throttled.rate=700000000,follower.replication.throttled.rate=700000000 1 2 3 > bin/kafka-configs.sh --describe --zookeeper localhost:2181 --entity-type topics Configs for topic 'my-topic' are leader.replication.throttled.replicas=1:102,0:101, follower.replication.throttled.replicas=1:101,0:102 74