一次kafka一直rebalance的定位与处理

前端时间咱们自研了一个kafka->elasticsearch导数据的小程序,咱们启动了多个副本。因为须要限速,可能会有中止接收消息的时间段,会致使中止和kafka的心跳,致使kafka一直处于rebalance的状态,经过查阅文档发现下面相关的几个参数前端 session.timeout.ms is for heartbeat thread. If coordinator fails to ge
相关文章
相关标签/搜索