@Tongwin
设计时，同一个消费者组，一般一个消费者能分到至少一个分区。建议你看看项目代码，确定消费者和分区数量配比

@Tongwin
无法理解你设计的时候为什么会有没分配到分区的消费者...
这和分区无关，每个 consumer 都负责 1...N 个分区，简单的就是确保每个 consumer 在上一批完成后再拉取。
你上一次拉了 500 只 commit 了 200 条，consumer 内部也不会让你本地堆积 800 条。
@tomorrow092
OP 的问题很有可能是把拉取到任务提交到线程池后就 commit offset 了，对于 kafka broker 和 consumer 来说就是消费完了。
所以就导致了线程池任务还在跑，consumer 又拉一批过来...然后满了 爆了... rebalance 了等等....

自己写代码调用 poll ，可以定时，也可以用 future 控制上一批消费完了再 poll ，注意 rebalance

如果你要控制所有消费者和对应 topic 一起的单批次数量，那就麻烦了。

@RichardX2023
trx_id 说明了一切....

甭管多少个月薪资，主张 n+1 基数就是你过去一年的收入除以 12

@doanything
拿到离职证明后 继续仲裁。 人家耍赖就是拿捏这个把柄，现在把柄没了 还不硬起来
录音也没用，旧公司那种属于用离职证明胁迫你。法院判的时候肯定会看到这一点。

@ppto
OP 和我们说的不在同一个线~~~~~ 所以我才说上锁
lock conn
exec select & read result
unlock
这样就不会了。

@RichardX2023
共享同一个数据连接的两个任务 是不会死锁的。

@ppto
每次用到 fd 去操作时 加锁就好了。

@twofox
绷不住了，看了 OP 回复 1 楼给的提示才是真的绷不住

@Greendays

有考察过显卡，这玩意只能装半高显卡，都是专业拿来绘图的，打游戏性价比很低不适合

@janus77
在国内这环境，等你意识到开始用思想的时候 就已经来不及了。
其实 CS 的人本科阶段，把 C 用好，算法和数据结构学好。操作系统也熟悉，最好看一些 linux kernel 源码，体会一下数据结构和算法的在里面的应用 就够了
不考研的话，等到大四，再补一点 CPP 或者 Java 就够了

ACM ，数学建模，编译原理接触下就行了。

外面不缺程序员是真的
但是外面这样工资的工作找起来很容易也是真的

这和线程多少有什么关系？也不需要分布式事务。这一批任务无论多少，开多少线程，从头到尾只是用一个数据库连接。 开始时关闭自动提交，所有任务跑完 commit 一下就好了

@akiyamamio
看了窗外，发现外面没人想坐在我这位置上。因为窗外看到的是军用机场，人们更想做到战斗机或者 Y20 的位置上的

定义一种或者两种 O 就行了 再多就是自找麻烦

@icoming
没活动的时候 2C1G 是 $16.5
怎么感觉还是没活动的时候 合算啊
1c512MB 几乎没其他用途，2C1G 用处就多很多啊

@icoming
有时候还能刷出来 刚就刷出来了 不过我还要注册 ...

自住的话 能不买就不买。除非你不敏感，且其他条件真的很好

@crazyTanuki 对前端一无所知 给点具体的提示或者样例网址么？