极客观点
项目管理
HarmonyOS
场景是使用kafka来收集前端请求数据，后端启动golang写的消费者来消费数据并计算。
目前发现单台消费者占用CPU过高，想部署多台。但是多台机器会导致启动多个消费者加入了同一个消费者组。
那么kafka有没有内部机制来平衡多个机器加入同一个消费者组的消息分配呢？
就是说，要保证两台机器启动起来的消费者均衡，而不是第一台加入消费者组的消费者太多。
java
- 可以增加partition， 比如32个partition， 将消息按照一定逻辑 pub 到不同的partition 里面
- 启动多个消费者，使用相同的消费组。 程序将自动分配 parititon 进行消费
撰写回答
你尚未登录，登录后可以
- 和开发者交流问题的细节
- 关注并接收问题和回答的更新提醒
- 参与内容的编辑和改进，让解决方法与时俱进
推荐问题
求救，我现在想批量给500多台线上linux服务器下发脚本有什么好用的图形化工具推荐嘛？
一台一台执行太慢了，有什么工具推荐，后期可能要经常批量推送。7 回答5.6k 阅读
为什么在Go中传递指针 解引用赋值后修改属性不改变原值？
指针传参，如果通过解引用获得原值后直接修改属性，则外层属性也会修改。这个很好理解。但为什么再赋值一次，就不是这样的结果呢？有如下代码 {代码...} 最后的输出结果是这样 {代码...} 一个是person2 := *personperson2.age = 55另一个是 (*person).age = 55为什么上面那个没有修改原值，下面修改了原值，我理解此时都...6 回答7.1k 阅读✓ 已解决
Spring中的两个疑惑?
使用注解的写法是否违背了Spring诞生的初衷？看了很多Spring教程，在讲述为什么要使用Spring的时候，都提出了一个很重要的原因就是，以前的8 回答6.5k 阅读
诺依框架自动生成代码前端Vue3提交数据，后端Java没收到问题出在哪里？
使用诺依框架自动生成代码功能。前端在请求地址处打印提交数据（有数据）如下图，后端Debug模式，进入断点查看数据如下图所示（无数据），问题一般出在哪里？========== Payload ===========4 回答703 阅读✓ 已解决
java连redis-sentinel连不上,接下来如何排查?
java连redis-sentinel连不上Java连接redis-sentinel连不上redis-sentinel是在k3s上部署的,使用helm部署的用命令行查看一切正常但是使用java连接报错,详细信息如下环境准备因为java的pod里面是没有redis的,所以下载一个redis-cli,然后拷贝的pod里面,再用命令行连接 {代码...} 安装redis到pod中 {代码...} 直接连接主节点...2 回答3.4k 阅读
浏览器能请求到数据怎么换了api工具或是爬虫都没数据了呢？
4 回答2.6k 阅读
阿里的EasyExcel报错， Can not close IO.] with root cause java.io.IOException: Broken pipe？
我这边本地没有复现该问题，线上导出的数据条数大概再1000行就不行了，但是本地是可以导出3000+的数据，且断点过长也没有触发客户端主动断开，从请求导出到断开只有3秒左右，再帖一下导出方法，能力有限，都没有解决 望各位大佬看一眼。错误日志在最下面3 回答1.9k 阅读✓ 已解决
每个分区只能被同一个消费组里面的一个消费者实例占用，所以你可以增加分区，然后用一致性hash的方式保证每个分区中的消息数量均衡