Spring 开机测试kafka

lmyy7pcs  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(262)

我使用的是spring boot版本2.1.8.release,我遇到了以下问题:
你有解决办法吗?

[Thread-2] ERROR o.a.k.t.TestUtils - Error deleting C:\Users\usr\AppData\Local\Temp\kafka-255644115154741962
java.nio.file.FileSystemException: C:\Users\usr\AppData\Local\Temp\kafka-255644115154741962\version-2\log.1: 
The process cannot access the file because it is being used by another process.
    at sun.nio.fs.WindowsException.translateToIOException(WindowsException.java:86)
    at sun.nio.fs.WindowsException.rethrowAsIOException(WindowsException.java:97)
    at sun.nio.fs.WindowsException.rethrowAsIOException(WindowsException.java:102)
    at sun.nio.fs.WindowsFileSystemProvider.implDelete(WindowsFileSystemProvider.java:269)
    at sun.nio.fs.AbstractFileSystemProvider.delete(AbstractFileSystemProvider.java:103)
    at java.nio.file.Files.delete(Files.java:1126)
    at org.apache.kafka.common.utils.Utils$2.visitFile(Utils.java:734)
    at org.apache.kafka.common.utils.Utils$2.visitFile(Utils.java:723)
    at java.nio.file.Files.walkFileTree(Files.java:2670)
    at java.nio.file.Files.walkFileTree(Files.java:2742)
    at org.apache.kafka.common.utils.Utils.delete(Utils.java:723)
    at org.apache.kafka.test.TestUtils$1.run(TestUtils.java:184)

这是我的测试,我用的是Windows10之类的操作系统,这是我的测试,

import org.I0Itec.zkclient.ZkClient;
import org.junit.Test;

import kafka.utils.ZKStringSerializer$;
import kafka.utils.ZkUtils;
import kafka.zk.EmbeddedZookeeper;

public class BaseTest {

private static final String ZKHOST = "127.0.0.1";

@Test
public void producerTest(){

    // setup Zookeeper
    EmbeddedZookeeper zkServer = new EmbeddedZookeeper();
    String zkConnect = ZKHOST + ":" + zkServer.port();
    ZkClient zkClient = new ZkClient(zkConnect, 30000, 30000, ZKStringSerializer$.MODULE$);
    ZkUtils zkUtils = ZkUtils.apply(zkClient, false);

    zkClient.close();
    zkServer.shutdown();
}
}

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题