Tongwin 最近的时间轴更新
Tongwin

Tongwin

V2EX 第 509274 号会员,加入于 2020-09-23 09:14:47 +08:00
今日活跃度排名 2132
Java 消费 Kafka 如何精确控制部分 consumer 的消费速率?
Java  •  Tongwin  •  144 天前  •  最后回复来自 Tongwin
44
深圳收台二手 kindle
二手交易  •  Tongwin  •  208 天前  •  最后回复来自 beayrdghkj
1
持币 200-300 收张玩网游的显卡
二手交易  •  Tongwin  •  274 天前  •  最后回复来自 Tongwin
11
2023 年,求推荐深圳洗牙方案
问与答  •  Tongwin  •  328 天前  •  最后回复来自 ggmood
10
[深圳] 收永诺 50mm f1.8/85mm f1.8 镜头 Z 卡口
二手交易  •  Tongwin  •  349 天前  •  最后回复来自 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
深圳电信宽带求助
宽带症候群  •  Tongwin  •  2022-10-09 14:47:47 PM  •  最后回复来自 HFX3389
19
迫于也没收到,继续收 2016-2017 款 MBP 8+256,坐标深圳
二手交易  •  Tongwin  •  2021-11-05 16:47:35 PM  •  最后回复来自 czwstc
11
Tongwin 最近回复了
@Tongwin 虽说工资单里填的是基础工资+绩效工资,但实际每月到手工资是固定的
@ashin op 你好,我想请问下,假如公司发放工资单里分有基础工资以及其他工资明细,然后公积金里的缴纳基数是按照基础工资缴纳的,这种也能成功追缴么?
31 天前
回复了 coloz 创建的主题 宽带症候群 宽带因为挂 NAS 被封了
@hcocoa 是运营商扫你的服务,封境外 ip 只能起到防攻击效果吧?
31 天前
回复了 coloz 创建的主题 宽带症候群 宽带因为挂 NAS 被封了
@hcocoa 我搞过 wireguard ,应该跟 tailscale 这些差不多。走 vpn 管道,相当于哪个设备要连局域网内的服务都要搞一次代理才能够连。 你这连 sp 应该也是同理。还是挺麻烦的。
低端口更容易被运营商扫到吧
111 天前
回复了 erwin985211 创建的主题 iPhone 关于 iphone16 基础班猜测(个人向)
手持 xsmax ,是现在 8200 买一台 15pm 还是等等 16pm 呢?
144 天前
回复了 rookie333 创建的主题 问与答 不懂就问,这种私服会有大哥玩吗?
请问下这种场景能实现么?
动态公网 ip+DDNS+内网 docker 部署游戏, 能够提供给几个基友在外网玩么?
@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 以及项目设计有了进一步的认识。
@flmn hi 大佬,我昨天就已经在测试了,配置大概是 max.poll.record 设置为 200 ,fetch.min.bytes 使用默认值。 通过限流打日志查看,每一次 poll 都是 200 。不过是在本地单实例跑的。 我大概懂你意思了,你说的情况应该是,我在消费的同时,上游也在造数据。如果我的消费速度超过生产速度,那么确实会出现,上游推来一条,我就消费 1 条的情况。
关于   ·   帮助文档   ·   博客   ·   API   ·   FAQ   ·   实用小工具   ·   954 人在线   最高记录 6679   ·     Select Language
创意工作者们的社区
World is powered by solitude
VERSION: 3.9.8.5 · 24ms · UTC 21:35 · PVG 05:35 · LAX 14:35 · JFK 17:35
Developed with CodeLauncher
♥ Do have faith in what you're doing.