commit 89b621f43e6771f91e766d74d3a851511b954da3
author Christian Schneider <chris@die-schneider.net> Tue Aug 08 11:30:12 2017 +0200
committer Christian Schneider <chris@die-schneider.net> Tue Aug 08 11:30:12 2017 +0200
tree 7954d5324ebcc0dc8f6d51f0dd5e0f7da765f7a1
parent 1f11156a4373881e91cfd147794040bdd415a846

Ignore kafka tests until we have an embedded kafka test server

rcomp-kafka/pom.xml

diff --git a/rcomp-kafka/pom.xml b/rcomp-kafka/pom.xml
index 80f05cf..7d1f5ea 100644
--- a/rcomp-kafka/pom.xml
+++ b/rcomp-kafka/pom.xml
@@ -31,14 +31,13 @@
             <artifactId>rcomp-api</artifactId>
         </dependency>
         <dependency>
+            <groupId>io.projectreactor</groupId>
+            <artifactId>reactor-core</artifactId>
+        </dependency>
+        <dependency>
             <groupId>org.apache.kafka</groupId>
             <artifactId>kafka-clients</artifactId>
             <version>0.11.0.0</version>
         </dependency>
-        <dependency>
-            <groupId>io.projectreactor</groupId>
-            <artifactId>reactor-core</artifactId>
-            <scope>test</scope>
-        </dependency>
     </dependencies>
 </project>
\ No newline at end of file

rcomp-kafka/src/test/java/org/apache/karaf/rcomp/kafka/TestKafka.java

diff --git a/rcomp-kafka/src/test/java/org/apache/karaf/rcomp/kafka/TestKafka.java b/rcomp-kafka/src/test/java/org/apache/karaf/rcomp/kafka/TestKafka.java
index 59528e2..8590821 100644
--- a/rcomp-kafka/src/test/java/org/apache/karaf/rcomp/kafka/TestKafka.java
+++ b/rcomp-kafka/src/test/java/org/apache/karaf/rcomp/kafka/TestKafka.java
@@ -25,6 +25,7 @@
 import org.apache.kafka.clients.producer.ProducerRecord;
 import org.apache.karaf.rcomp.kafka.KafkaComponent;
 import org.junit.Assert;
+import org.junit.Ignore;
 import org.junit.Test;
 import org.reactivestreams.Subscriber;
 
@@ -36,6 +37,7 @@
     private static final String TOPIC1 = "topic1";
     private static final String TOPIC2 = "topic2";
 
+    @Ignore
     @Test
     public void testWithConsumerRecord() throws Exception {
         KafkaComponent kafka = createComponent();
@@ -55,6 +57,7 @@
         Assert.assertEquals("test", received.get(0));
     }
 
+    @Ignore
     @Test
     public void testWithString() throws Exception {
         KafkaComponent kafka = createComponent();