import org.springframework.kafka.test.context.EmbeddedKafka;
import org.springframework.test.context.junit.jupiter.SpringExtension;
-import java.time.Duration;
import java.util.concurrent.CompletableFuture;
import static de.juplo.kafka.ApplicationTests.PARTITIONS;
import static de.juplo.kafka.ApplicationTests.TOPIC;
-import static org.awaitility.Awaitility.*;
@ExtendWith(SpringExtension.class)