记忆中的猫

0 声望

这家伙太懒,什么都没留下

个人动态

半兽人 如何设置kafka的内存大小 发表评论:

1、kafka会尽量的利用当前机器空余的内存来进行缓存消息(包含页缓存),但是这些属于buff/cache,当有其他的进程需要缓存的时候,kafka会立即释放这些buff/cache的,所以没啥影响,不会引起oom。
2、消费者消费不及时,是消费者逻辑的问题,跟kafka无关,消费者拿到消息之后,检查它自身的逻辑。
3、kafka的消息是持久化的,积压多少只要磁盘够,都没差。

2月前
2月前
半兽人 kafka 怎么在生产者发送数据之前,使用Java代码检测网络状态、检测kafka集群运行状态呢 发表评论:

如果你用官方的客户端的话,kafka连接池会默认检测心跳,等重连机制的,你用关注这些的。

2月前
关注了用户 半兽人 · 2月前
半兽人 kafak 2.3 报错文件打开过多错误 java.io.IOException: Too many open files 发表评论:

系统的openfile要调一下,方式:
https://www.orchome.com/131

另外,openfile too many 也有可能是其他程序影响的(linux上其他的程序),如果是其他的,关掉即可,如果是kafka的,可用以上链接,调整系统的openfile数。

2月前