Kafka限流
2024-10-20 18:55:36
1. 客户端认证
如果kafka客户端是认证的,那么可以使用userId和clientId两种认证方式。如果没有认证只能使用clientId限流。
bin/kafka-configs.sh --zookeeper localhost: --alter --add-config 'producer_byte_rate=1048576,consumer_byte_rate=1024' \
--entity-type clients --entity-name clientA
对clientId=clientA的客户端添加限流设置。producer_byte_rate表示每秒最多能写入到消息量,单位为byte/sec。consumer_byte_rate表示每秒最多能消费的消息了,单位也为byte/sec。设置后立即生效。
2. Producer & Consumer设置
在producer和consumer的配置中需要加入client.id配置:
Producer:
props.put(ProducerConfig.CLIENT_ID_CONFIG, "clientA");
Consumer:
props.put(ConsumerConfig.CLIENT_ID_CONFIG, "clientA");
限流效果:
3. 查看限流信息
zookeeper:
[zk: localhost:(CONNECTED) ] get /config/clients/clientA
{"version":,"config":{"producer_byte_rate":"","consumer_byte_rate":""}}
最新文章
- premere cs4绿色版 安装 并且 视频导出 讲解
- Ajax使用WCF实现小票pos机打印源码
- Python第一天 - 函数
- win10本地搭建apache+php+mysql运行环境
- Eclipse里面的一些常规设置
- 【FFmpeg】Windows下FFmpeg编译
- java 递归获取一个目录下的所有文件路径
- Java基础总结(备考)
- [AC自动机]HDOJ3695 Computer Virus on Planet Pandora
- spark-shell 执行脚本并传入参数
- NGUI研究之在Unity中使用贝塞尔曲线
- poj3928 la4329 pingpong
- solr 的 field, copyfield ,dynamic field
- Eclipse使用JDBC小案例
- c语言的一些易错知识积累
- nodejs+express+mongodb简单的例子
- canvas绘图基础
- Docker 容器备份例子
- Vue.extend提供自定义组件的构造器
- 各种学习Demo链接