应该是文件句柄没有正常释放,由于某些程序还在占用,导致文件并没有真正删除,所以消费还能消费到。
用 lsof | grep deleted 查看是否有对应的kafka日志文件,应该就能判断。
里面有提到“javax.security.auth.login.name”和 “javax.security.auth.login.password”。
自己测咯
官网就有 https://kafka.apache.org/documentation/#security_sasl ,使用 SASL/PLAIN 方式,而且百度也是一大推啊