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 473f3ec..55337da 100644 --- a/processor-samples/polled-consumer/src/test/java/demo/PolledConsumerApplicationTests.java +++ b/processor-samples/polled-consumer/src/test/java/demo/PolledConsumerApplicationTests.java @@ -28,7 +28,6 @@ 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; @@ -68,7 +67,6 @@ public class PolledConsumerApplicationTests { } @Test - @Ignore public void testSendReceive() throws Exception { Map senderProps = KafkaTestUtils.producerProps(embeddedKafka.getEmbeddedKafka()); senderProps.put("key.serializer", ByteArraySerializer.class);