字节 kafka: 发消息的流程 comsumer group vs partition comsumer rebalance? ISR? 消息堆积处理方法？ 要么加线程(partitoin) 要么批量 成批poll, 事务功能关闭 增加partition，consumer数量，consumer用工作线程加阻塞队列来接收 如果是有大量提交失败导致重复消费，需要看一下原因session.timeout.ms es: es 倒排索引，支持事务支持吗 从节点可以写入吗？ 写入流程？写到内存还是磁盘？ 写入buffer 和translog -> 定期同步buffer到os cahce...