test_log-0 in dir D:\tmp\kafka-logs Caused by: java.nio.file.FileSystemExcept 错误问题

标签：rod   run   fse   nio   就是   异步   loading   解决   bsp   

启动完kafka后，go run producer.go 程序之后出现

 D:\tmp\kafka-logs\__consumer_offsets-48\00000000000000000000.test_log.log: 另一个程序正在使用此文件，进程无法访问。

解决办法，网上说，直接把tmp的这个配置日志的文件夹下的 给清空 ，测试了还是不行。

那就是代码出现了问题，查询代码发现一个问题

在consumer.go的代码中，异步去处理分区的时候，会有一个

defer pc.AsyncClose()

我写的成了

defer pc.Close()

修改成AsyncClose()，在重启一下kafka 就可以使用了

test_log-0 in dir D:\tmp\kafka-logs Caused by: java.nio.file.FileSystemExcept 错误问题

标签：rod   run   fse   nio   就是   异步   loading   解决   bsp   

原文地址：https://www.cnblogs.com/pebblecome/p/14363204.html