本来是一个悲伤的故事，看到这句

"Rust 都快入门成功了"

你成功把我逗笑了。

有没有可能根本不需要限流。
kafka 本来让业务主动去拉取，就是让你在拉取的时候控制速率。

fetch-max-wait: 10000 # poll 一次拉取的阻塞的最大时长，单位：毫秒。这里指的是阻塞拉取需要满足至少 fetch-min-size 大小的消息
fetch-min-size: 10 # poll 一次消息拉取的最小数据量，单位：字节
max-poll-records: 100 # poll 一次消息拉取的最大数量

可以完全通过这三个参数控制你的消费速率，直接同步消费就是最好的选择。你却本末倒置，做异步消费然后再限流。本来配置修改一下就可以的事情，你却写一堆代码，把简单的事情搞复杂。

新需求：现需要新增消费一个 topic ，该 topic 的量比存量的 topic 要远远大于。因此需要控制一下该 topic 每个批次消费到的数量

先把问题表述清楚吧。。。。。你自己看看你说的是啥

两个不同的消费者消费不同的 topic ，这俩之间没任何逻辑上的关系的，所以你限制数量是为了啥？？？？？？？？

有没有可能换个思路会好点，比如 webdav+挂载到本地磁盘。

感谢分享！

@saigo 现在 size 不是问题吧，电脑上硬盘动不动就上 IT 的。

单单就职位比较。
运维开发就是运维，你入行都是运维了，后面转不了开发的，就算阿里的运维也一样。

@pxiphx891
DataGrip 收费的把。

webdav 客户端，直接用 Finder 不就能挂载吗？
这个说的是 mac 下的吧?这个不如那几个收费的稳定，比如 Mountain duck ，QSpace 。

@dianso 已经添加。在转换工具-->全角/半角

@aeiou520 抱歉, 刚刚重新发布了一下,现在有了

https://groups.google.com/g/golang-nuts/c/nUMvimzSZvk
不知道是不是和这个有关系，用 go build 后的二进制包启动，而不是用 go run 启动进程。

地理位置不说，需求没有，让老哥们凭空猜是吧。

你东北和内蒙就不要想着电车了，冬天打折打到你哭，

1 秒 200 万请求，假设 lambda 并发 100k,则每个 lambda 在 1 秒内需要处理 20 个请求，平均每个请求的相应时间不超过 50ms 。

理论上 lambda 和后端机器一样，是无状态的，所以可以任意扩展。

你 1 秒 200 万的请求，真正的瓶颈在后端数据库/缓存。这些有状态的才是你们系统的瓶颈。

@dianso 收到。

@aeiou520 release 下有打包好的 window 平台和 mac 平台下的安装包

一个运维，一个是研发。其他的不用比了，无脑选华为

写 java 社区版够用了。。。。10 年 javer 路过
写 rust/react 用 vscode 。

广告联盟阿