Tongwin 最近的时间轴更新 Tongwin 最近的时间轴更新 |
TongwinV2EX 第 509274 号会员，加入于 2020-09-23 09:14:47 +08:00今日活跃度排名 1145 |
| Java 消费 Kafka 如何精确控制部分 consumer 的消费速率？ Java • Tongwin • 136 天前 • 最后回复来自 Tongwin | 44 |
| 深圳收台二手 kindle 二手交易 • Tongwin • 200 天前 • 最后回复来自 beayrdghkj | 1 |
| 持币 200-300 收张玩网游的显卡 二手交易 • Tongwin • 266 天前 • 最后回复来自 Tongwin | 11 |
| 2023 年，求推荐深圳洗牙方案 问与答 • Tongwin • 320 天前 • 最后回复来自 ggmood | 10 |
| [深圳] 收永诺 50mm f1.8/85mm f1.8 镜头 Z 卡口 二手交易 • Tongwin • 341 天前 • 最后回复来自 Tongwin | 4 |
| 深圳 1450 元面交出 xps13 9360 二手交易 • Tongwin • 2023-04-10 17:35:52 PM • 最后回复来自 Tongwin | 4 |
| [深圳]迫于 XPS13 退休，收 m1 macbook air 8+256 二手交易 • Tongwin • 2022-11-25 15:25:36 PM • 最后回复来自 Tongwin | 2 |
| 迫于电视，收 xbox 手柄 +N1 电视盒子 二手交易 • Tongwin • 2022-01-10 16:07:38 PM |
| 迫于也没收到,继续收 2016-2017 款 MBP 8+256，坐标深圳 二手交易 • Tongwin • 2021-11-05 16:47:35 PM • 最后回复来自 czwstc | 11 |
Tongwin 最近回复了
2 天前 回复了 ashin 创建的主题 › 深圳 › 今天去办理了公积金追缴投诉，能拿到几万块，关于深圳公积金追缴投诉攻略看这一篇就够了！ |
@Tongwin 虽说工资单里填的是基础工资+绩效工资，但实际每月到手工资是固定的
2 天前 回复了 ashin 创建的主题 › 深圳 › 今天去办理了公积金追缴投诉，能拿到几万块，关于深圳公积金追缴投诉攻略看这一篇就够了！ |
@ashin op 你好，我想请问下，假如公司发放工资单里分有基础工资以及其他工资明细，然后公积金里的缴纳基数是按照基础工资缴纳的，这种也能成功追缴么？
23 天前 回复了 coloz 创建的主题 › 宽带症候群 › 宽带因为挂 NAS 被封了 |
@hcocoa 是运营商扫你的服务，封境外 ip 只能起到防攻击效果吧？
23 天前 回复了 coloz 创建的主题 › 宽带症候群 › 宽带因为挂 NAS 被封了 |
@hcocoa 我搞过 wireguard ，应该跟 tailscale 这些差不多。走 vpn 管道，相当于哪个设备要连局域网内的服务都要搞一次代理才能够连。 你这连 sp 应该也是同理。还是挺麻烦的。
99 天前 回复了 Exp 创建的主题 › 宽带症候群 › 为什么都说家宽下如果搭建服务不建议使用低端口号，容易被封？ |
低端口更容易被运营商扫到吧
103 天前 回复了 erwin985211 创建的主题 › iPhone › 关于 iphone16 基础班猜测（个人向） |
手持 xsmax ，是现在 8200 买一台 15pm 还是等等 16pm 呢？
136 天前 回复了 rookie333 创建的主题 › 问与答 › 不懂就问，这种私服会有大哥玩吗? |
请问下这种场景能实现么？
动态公网 ip+DDNS+内网 docker 部署游戏， 能够提供给几个基友在外网玩么？
动态公网 ip+DDNS+内网 docker 部署游戏， 能够提供给几个基友在外网玩么？
136 天前 回复了 Tongwin 创建的主题 › Java › Java 消费 Kafka 如何精确控制部分 consumer 的消费速率？ |
@codedreamstar 大佬真的万分抱歉，1 周后才来回复你信息。 最近杂事缠身。我们用 kafka 并不是自己封装的，也是使用正常的依赖，由于本身架构问题，所以没法使用 Spring for kafka 。不过后续我们需要重构这个项目，后面以 SpringBoot 来框架进行搭建就会用 Spring for kafka 去设计了。 尴尬的是中间进程下发 B 是没有限流逻辑，我们后面会优先开发这一块。之前的数据的实时速率都没有达到应用 B 的峰值。
后面应用重构，确实是考虑过把 redis 砍掉，原有 redis 功能是为了保证数据不丢失（比如应用 B 处理失败，应用 A 有相关的重发机制），后续重构我的想法是砍掉 redis ， 消费 topic 进而下发数据，如果应用 B 处理失败，则应用 A 把失败的数据推送到另一个 topic-C 。 应用 A 继续消费 topic-C 的数据来实现重发机制。
感谢大佬提供的思路，让我对 kafka 以及项目设计有了进一步的认识。
后面应用重构，确实是考虑过把 redis 砍掉，原有 redis 功能是为了保证数据不丢失（比如应用 B 处理失败，应用 A 有相关的重发机制），后续重构我的想法是砍掉 redis ， 消费 topic 进而下发数据，如果应用 B 处理失败，则应用 A 把失败的数据推送到另一个 topic-C 。 应用 A 继续消费 topic-C 的数据来实现重发机制。
感谢大佬提供的思路，让我对 kafka 以及项目设计有了进一步的认识。
144 天前 回复了 Tongwin 创建的主题 › Java › Java 消费 Kafka 如何精确控制部分 consumer 的消费速率？ |
@flmn hi 大佬，我昨天就已经在测试了，配置大概是 max.poll.record 设置为 200 ，fetch.min.bytes 使用默认值。 通过限流打日志查看，每一次 poll 都是 200 。不过是在本地单实例跑的。 我大概懂你意思了，你说的情况应该是，我在消费的同时，上游也在造数据。如果我的消费速度超过生产速度，那么确实会出现，上游推来一条，我就消费 1 条的情况。
Select Language