How to use testSchemaRegistry method of org.testcontainers.redpanda.RedpandaContainerTest class

Best Testcontainers-java code snippet using org.testcontainers.redpanda.RedpandaContainerTest.testSchemaRegistry

Source:RedpandaContainerTest.java

...56            .isInstanceOf(IllegalArgumentException.class)57            .hasMessageContaining("Redpanda version must be >= v22.2.1");58    }59    @Test60    public void testSchemaRegistry() {61        try (RedpandaContainer container = new RedpandaContainer(REDPANDA_DOCKER_IMAGE)) {62            container.start();63            String subjectsEndpoint = String.format(64                "%s/subjects",65                // getSchemaRegistryAddress {66                container.getSchemaRegistryAddress()67                // }68            );69            String subjectName = String.format("test-%s-value", UUID.randomUUID());70            Response createSubject = RestAssured71                .given()72                .contentType("application/vnd.schemaregistry.v1+json")73                .pathParam("subject", subjectName)74                .body("{\"schema\": \"{\\\"type\\\": \\\"string\\\"}\"}")...

testSchemaRegistry

Using AI Code Generation

1import org.junit.jupiter.api.Test;2import org.testcontainers.containers.Network;3import org.testcontainers.containers.output.Slf4jLogConsumer;4import org.testcontainers.junit.jupiter.Container;5import org.testcontainers.junit.jupiter.Testcontainers;6import org.testcontainers.redpanda.RedpandaContainer;7import java.util.concurrent.TimeUnit;8import static org.assertj.core.api.Assertions.assertThat;9public class RedpandaContainerTest {10    private static final RedpandaContainer redpanda = new RedpandaContainer()11            .withNetwork(Network.newNetwork())12            .withNetworkAliases("redpanda")13            .withExposedPorts(9092)14            .withLogConsumer(new Slf4jLogConsumer(RedpandaContainerTest.class));15    public void testSchemaRegistry() throws Exception {16        redpanda.start();17        redpanda.testSchemaRegistry();18        assertThat(redpanda.isRunning()).isTrue();19        TimeUnit.MINUTES.sleep(5);20    }21}22public void testSchemaRegistry() {23        try (final KafkaProducer<String, String> producer = new KafkaProducer<>(producerProperties())) {24            final Schema schema = SchemaBuilder.struct().name("test").field("field", Schema.STRING_SCHEMA).build();25            final Struct struct = new Struct(schema).put("field", "value");26            final ProducerRecord<String, String> record = new ProducerRecord<>(TOPIC, struct.toString());27            producer.send(record).get();28        } catch (Exception e) {29            throw new RuntimeException(e);30        }31    }

testSchemaRegistry

Using AI Code Generation

1import org.testcontainers.containers.Network;2import org.testcontainers.containers.output.Slf4jLogConsumer;3import org.testcontainers.containers.wait.strategy.Wait;4import org.testcontainers.redpanda.RedpandaContainer;5import org.testcontainers.utility.DockerImageName;6import org.testcontainers.utility.MountableFile;7import org.testcontainers.utility.TestEnvironment;8import java.io.File;9import java.io.IOException;10import java.nio.file.Files;11import java.nio.file.Path;12import java.nio.file.Paths;13import java.time.Duration;14import java.util.HashMap;15import java.util.Map;16import static org.rnorth.visibleassertions.VisibleAssertions.assertEquals;17import static org.rnorth.visibleassertions.VisibleAssertions.assertTrue;18public class RedpandaContainerTest {19    private static final String TOPIC_NAME = "test-topic";20    private static final String SCHEMA_NAME = "test-schema";21    private static final String SCHEMA_VALUE = "{ \"type\": \"string\" }";22    public void testSimple() throws IOException, InterruptedException {23        try (RedpandaContainer redpanda = new RedpandaContainer()) {24            redpanda.start();25            redpanda.createTopic(TOPIC_NAME);26            String message = "test-message";27            redpanda.execInContainer("rpk", "topic", "produce", TOPIC_NAME, "-p", "0", "-r", "0", "-v", message);28            String output = redpanda.execInContainer("rpk", "topic", "consume", TOPIC_NAME, "-b", "0", "-o", "0", "-c", "1");29            assertTrue("Output should contain the message", output.contains(message));30        }31    }32    public void testSchemaRegistry() throws IOException, InterruptedException {33        try (RedpandaContainer redpanda = new RedpandaContainer()) {34            redpanda.start();35            redpanda.createTopic(TOPIC_NAME);36            redpanda.createSchema(SCHEMA_NAME, SCHEMA_VALUE);37            String message = "test-message";38            redpanda.execInContainer("rpk", "topic", "produce", TOPIC_NAME, "-p", "0", "-r", "0", "-v", message, "--schema-id", "

testSchemaRegistry

Using AI Code Generation

1RedpandaContainer redpanda = new RedpandaContainer()2    .withSchemaRegistry(true);3redpanda.start();4redpanda.testSchemaRegistry();5redpanda.stop();6redpanda.close();7}

testSchemaRegistry

Using AI Code Generation

1public static void testSchemaRegistry(RedpandaContainer<?> container) {2    assertThat(container.isSchemaRegistryEnabled()).isTrue();3    String schemaRegistryUrl = container.getSchemaRegistryUrl();4    assertThat(schemaRegistryUrl).isNotEmpty();5    try (CloseableHttpClient httpClient = HttpClients.createDefault()) {6        HttpGet httpGet = new HttpGet(schemaRegistryUrl + "/config");7        CloseableHttpResponse response = httpClient.execute(httpGet);8        assertThat(response.getStatusLine().getStatusCode()).isEqualTo(200);9    } catch (IOException e) {10        throw new RuntimeException(e);11    }12}

testSchemaRegistry

Using AI Code Generation

1RedpandaContainer redpanda = new RedpandaContainer()2    .withSchemaRegistry(true)3    .withNetwork(Network.newNetwork())4    .withNetworkAliases("redpanda");5redpanda.start();6redpanda.testSchemaRegistry();7redpanda.stop();8RedpandaContainer redpanda = new RedpandaContainer()9    .withKafkaConnect(true)10    .withNetwork(Network.newNetwork())11    .withNetworkAliases("redpanda");12redpanda.start();13redpanda.testKafkaConnect();14redpanda.stop();15RedpandaContainer redpanda = new RedpandaContainer()16    .withKafkaRest(true)17    .withNetwork(Network.newNetwork())18    .withNetworkAliases("redpanda");19redpanda.start();20redpanda.testKafkaRest();21redpanda.stop();22RedpandaContainer redpanda = new RedpandaContainer()23    .withKafkaStreams(true)24    .withNetwork(Network.newNetwork())25    .withNetworkAliases("redpanda");26redpanda.start();27redpanda.testKafkaStreams();28redpanda.stop();

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.