From fca77bb1da3b64d7a655f016eb505e1c9bed5ddc Mon Sep 17 00:00:00 2001 From: Marcos Paulo dos Santos Date: Tue, 18 Jun 2019 18:36:44 -0300 Subject: [PATCH] #150 - Removed deprecated class org.springframework.kafka.test.rule.KafkaEmbedded --- .../test/java/demo/EmbeddedKafkaApplicationTests.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/testing-samples/test-embedded-kafka/src/test/java/demo/EmbeddedKafkaApplicationTests.java b/testing-samples/test-embedded-kafka/src/test/java/demo/EmbeddedKafkaApplicationTests.java index 61031ba..9d7d68c 100644 --- a/testing-samples/test-embedded-kafka/src/test/java/demo/EmbeddedKafkaApplicationTests.java +++ b/testing-samples/test-embedded-kafka/src/test/java/demo/EmbeddedKafkaApplicationTests.java @@ -45,7 +45,7 @@ import org.springframework.boot.test.context.SpringBootTest; import org.springframework.kafka.core.DefaultKafkaConsumerFactory; import org.springframework.kafka.core.DefaultKafkaProducerFactory; import org.springframework.kafka.core.KafkaTemplate; -import org.springframework.kafka.test.rule.KafkaEmbedded; +import org.springframework.kafka.test.rule.EmbeddedKafkaRule; import org.springframework.kafka.test.utils.KafkaTestUtils; import org.springframework.test.context.junit4.SpringRunner; @@ -71,16 +71,16 @@ public class EmbeddedKafkaApplicationTests { private static final String GROUP_NAME = "embeddedKafkaApplication"; @ClassRule - public static KafkaEmbedded embeddedKafka = new KafkaEmbedded(1, true, OUTPUT_TOPIC); + public static EmbeddedKafkaRule embeddedKafka = new EmbeddedKafkaRule(1, true, OUTPUT_TOPIC); @BeforeClass public static void setup() { - System.setProperty("spring.cloud.stream.kafka.binder.brokers", embeddedKafka.getBrokersAsString()); + System.setProperty("spring.cloud.stream.kafka.binder.brokers", embeddedKafka.getEmbeddedKafka().getBrokersAsString()); } @Test public void testSendReceive() { - Map senderProps = KafkaTestUtils.producerProps(embeddedKafka); + Map senderProps = KafkaTestUtils.producerProps(embeddedKafka.getEmbeddedKafka()); senderProps.put("key.serializer", ByteArraySerializer.class); senderProps.put("value.serializer", ByteArraySerializer.class); DefaultKafkaProducerFactory pf = new DefaultKafkaProducerFactory<>(senderProps); @@ -88,7 +88,7 @@ public class EmbeddedKafkaApplicationTests { template.setDefaultTopic(INPUT_TOPIC); template.sendDefault("foo".getBytes()); - Map consumerProps = KafkaTestUtils.consumerProps(GROUP_NAME, "false", embeddedKafka); + Map consumerProps = KafkaTestUtils.consumerProps(GROUP_NAME, "false", embeddedKafka.getEmbeddedKafka()); consumerProps.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest"); consumerProps.put("key.deserializer", ByteArrayDeserializer.class); consumerProps.put("value.deserializer", ByteArrayDeserializer.class);