@Scarb 谢谢大佬, 我也找到这个方法了. 可以获取到 brokerOffset, 但是 consumerOffset 一直是 0

先谢谢各位大佬！

@INCerry 富哥，需求跟我差不多，只不过我 32G 够用，也没那么重游戏需求准备整个 4050 的。华硕 20 号发布会估计有灵耀 14pro 。明天 rog 发布会，不知道幻 14 怎么样。

@kwh 问题在于，如果这个参数不是一个列表，而是比如 string ，integer ，long ，这样都是可以的

@liu90729 大佬, 冒昧再问一个问题; 项目分为 api 和 server, api 定义了 api, model 和相关 validation, server 的 controller 做继承.
server 用的是 jdk17 并且升级了 springboot3.0; api 包想向外暴露为 jdk1.8 编译的, 但是因为 javax 的命名空间变成 jakarta 而 jdk8 是不能编译 jakarta 命名空间下的类的; 请问有什么好的解决办法吗

@liu90729 大佬太牛了

大家有想法嘛? 谢谢谢谢!

@lzgshsj 这个也试过了，会覆盖掉原本的 products 列表

@Moyyyyyyyyyyye thx, 不过这个只能在最外层再新建一个 productDetail 列表, 查出来不是我想要的这种结构

em.... 直接在 computeIfAbsent 的第二个参数, 也就是 Function 里做处理, 最后返回 null, 是不是也可行

有了一个 RestHighLevelClient 再注册一个 RestHighLevelClient... 没搞这是什么逻辑

@Dogod37 如果每次请求这个接口, 你都开 30 个, 算不合理操作;
如果你把 30 个线程的线程池作为一个 bean 注入, 每次调用这个接口, 都用这个线程池来跑, 就不算.
一般网络 IO 的阻塞系数大概是 0.8~0.9, 也就是说线程处理一个网络请求, 其中等待 remote 返回的时间大概占 80%到 90%, 这时候推荐创建的线程池线程数量是 CPU 核数 /(1 - 阻塞系数).
当然这只是理论上的, 还是得多次操作看具体.
可以用 CompletableFuture 做, 最后用 CompletableFuture.allOf 来阻塞等待完成

@laozhoubuluo 嗯嗯, 其实还是因为我说的只是极端情况. 目前等级的有效期有自然年, 相对天, 月, 年这些. 主要用到的是自然年. 所以等级重算这个任务每天都要去跑, 只是在年终的时候, 数据量会很大~
感谢大佬提供思路~

@laozhoubuluo 嗯嗯, 惰性更新这块是肯定要做的~
请问另一个请求在低峰期去请求接口这块, 大佬有什么好的实现思路吗? flink 时间窗口统计接口请求, 低于某值发送消息触发这样可行吗? 但是感觉复杂度又高了不少

@THESDZ
1. 不需求同一事物, 之前数据量比较小, 所以用单机器 ForkJoinPool 去跑的.
2. 实时性主要指用户以及其他服务可见的实时性, 写库不需要高实时性, 这也是为什么想先放在 redis 中

@MoYi123 嗯嗯, 这个是想到的补偿方案. 就是脏数据重算那里

@hannibalm 百万会员在年终进行等级重算. 不同等级对应不同重算规则. 需要更新成长值积分(另一个服务). 因为等级关联打折等情况, 所以如果算的慢, 就会造成经济损失

@laozhoubuluo 会保证计算时间内没有规则的新增和更改. 规则本身是确定的, 只是不同批量的数据需要对应不同规则去计算

如果有资源那就再冗余一份数据用 orderId 分片 = =