juplo.de Git - demos/kafka/chat/blob - src/test/java/de/juplo/kafka/chat/backend/KafkaConfigurationIT.java

   1 package de.juplo.kafka.chat.backend;
   2
   3 import org.springframework.boot.test.context.SpringBootTest;
   4 import org.springframework.kafka.test.context.EmbeddedKafka;
   5
   6 import static de.juplo.kafka.chat.backend.KafkaConfigurationIT.TOPIC;
   7
   8
   9 @SpringBootTest(
  10     webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT,
  11     properties = {
  12         "chat.backend.services=kafka",
  13         "chat.backend.kafka.client-id=TEST",
  14         "chat.backend.kafka.bootstrap-servers=${spring.embedded.kafka.brokers}",
  15         "chat.backend.kafka.topic=" + TOPIC,
  16         "chat.backend.kafka.num-partitions=3" })
  17 @EmbeddedKafka(topics = TOPIC, partitions = 3)
  18 class KafkaConfigurationIT extends AbstractConfigurationIT
  19 {
  20   final static String TOPIC = "TEST";
  21 }