好的博主,已解决,谢谢博主的提示,原因出现在配置文件没有生效。
单从日志来看,是你的配置没生效,不知道你是怎么使用的配置文件,你可以关注下日志确认你的配置是否生效。
还有,kafka.producer.buffer.memory
这种命名方式有可能是错的(我不太清楚你使用的什么客户端),如果是springboot,可以看看这篇SpringBoot和kafka集成。
相关buffer.memory
介绍参考:Kafka Producer配置
第一种可能是消息格式错误,重启后应后应该是启动不了的吧,第二种是守护进程,我感觉是使用的守护进程,因为重新启动后将所有的窗口关闭,消费者还是可以正常进行消费的。大佬资源的不足会不会也会导致消费者的自动停止。
你的消息量不大,超时是不会引起的。
还有2种可能:
1、kafka消费者报错(消息格式)。
2、不太清楚你kafka消费者启动的方式,但是一定要守护进程的方式启动(永不停止,后台运行,不会随着窗口的关闭而销毁)。