Fix travis connect test

tchiotludo · May 13, 2019 · f47cec0 · f47cec0
1 parent c906499
commit f47cec0
Showing 1 changed file with 8 additions and 4 deletions.
diff --git a/src/test/java/org/kafkahq/repositories/ConnectRepositoryTest.java b/src/test/java/org/kafkahq/repositories/ConnectRepositoryTest.java
@@ -52,20 +52,24 @@ public void cleanup() {
 
     @Test
     public void create() {
+        String path1 = ConnectRepository.class.getClassLoader().getResource("application.yml").getPath();
+        String path2 = ConnectRepository.class.getClassLoader().getResource("logback.xml").getPath();
+
         repository.create(
             KafkaTestCluster.CLUSTER_ID,
             "ConnectRepositoryTest",
             ImmutableMap.of(
                 "connector.class", "FileStreamSinkConnector",
-                "file", "/etc/hosts",
+                "file", path1,
                 "topics", "test-topics1"
             )
         );
 
+
         List<ConnectDefinition> all = repository.getDefinitions(KafkaTestCluster.CLUSTER_ID);
         assertEquals(1, all.size());
 
-        assertEquals("/etc/hosts", repository.getDefinition(
+        assertEquals(path1, repository.getDefinition(
             KafkaTestCluster.CLUSTER_ID,
             "ConnectRepositoryTest"
         ).getConfigs().get("file"));
@@ -75,12 +79,12 @@ public void create() {
             "ConnectRepositoryTest",
             ImmutableMap.of(
                 "connector.class", "FileStreamSinkConnector",
-                "file", "/etc/resolv.conf ",
+                "file", path2,
                 "topics", "test-topics1"
             )
         );
 
-        assertEquals("/etc/resolv.conf ", repository.getDefinition(
+        assertEquals(path2, repository.getDefinition(
             KafkaTestCluster.CLUSTER_ID,
             "ConnectRepositoryTest"
         ).getConfigs().get("file"));