diff --git a/processor-samples/polled-consumer/src/test/java/demo/PolledConsumerApplicationTests.java b/processor-samples/polled-consumer/src/test/java/demo/PolledConsumerApplicationTests.java index 55337da..473f3ec 100644 --- a/processor-samples/polled-consumer/src/test/java/demo/PolledConsumerApplicationTests.java +++ b/processor-samples/polled-consumer/src/test/java/demo/PolledConsumerApplicationTests.java @@ -28,6 +28,7 @@ import org.apache.kafka.common.serialization.ByteArrayDeserializer; import org.apache.kafka.common.serialization.ByteArraySerializer; import org.junit.BeforeClass; import org.junit.ClassRule; +import org.junit.Ignore; import org.junit.Test; import org.junit.runner.RunWith; @@ -67,6 +68,7 @@ public class PolledConsumerApplicationTests { } @Test + @Ignore public void testSendReceive() throws Exception { Map senderProps = KafkaTestUtils.producerProps(embeddedKafka.getEmbeddedKafka()); senderProps.put("key.serializer", ByteArraySerializer.class);