-package de.juplo.kafka.chat.backend;
+package de.juplo.kafka.chat.backend.implementation;
import com.fasterxml.jackson.core.type.TypeReference;
import com.fasterxml.jackson.databind.ObjectMapper;
-package de.juplo.kafka.chat.backend;
+package de.juplo.kafka.chat.backend.implementation;
import org.junit.jupiter.api.DisplayName;
import org.junit.jupiter.api.Test;
-package de.juplo.kafka.chat.backend;
+package de.juplo.kafka.chat.backend.implementation;
import org.springframework.boot.test.context.SpringBootTest;
-package de.juplo.kafka.chat.backend;
+package de.juplo.kafka.chat.backend.implementation;
import org.springframework.boot.test.context.SpringBootTest;
-package de.juplo.kafka.chat.backend;
+package de.juplo.kafka.chat.backend.implementation;
import lombok.extern.slf4j.Slf4j;
import org.junit.jupiter.api.BeforeEach;
-package de.juplo.kafka.chat.backend;
+package de.juplo.kafka.chat.backend.implementation;
import org.junit.jupiter.api.Disabled;
import org.springframework.boot.test.context.SpringBootTest;
-package de.juplo.kafka.chat.backend;
+package de.juplo.kafka.chat.backend.implementation;
import org.junit.jupiter.api.Disabled;
import org.springframework.boot.test.context.SpringBootTest;
-package de.juplo.kafka.chat.backend;
+package de.juplo.kafka.chat.backend.implementation;
import de.juplo.kafka.chat.backend.implementation.kafka.ChannelTaskExecutor;
import de.juplo.kafka.chat.backend.implementation.kafka.KafkaTestUtils;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.kafka.test.context.EmbeddedKafka;
-import static de.juplo.kafka.chat.backend.KafkaConfigurationIT.DATA_TOPIC;
-import static de.juplo.kafka.chat.backend.KafkaConfigurationIT.INFO_TOPIC;
+import static de.juplo.kafka.chat.backend.implementation.KafkaConfigurationIT.DATA_TOPIC;
+import static de.juplo.kafka.chat.backend.implementation.KafkaConfigurationIT.INFO_TOPIC;
@SpringBootTest(