Join the 1-day Testing & QA Summit featuring 15+ Expert Speakers.Register for FREE! Join TestMu Conference

How to use KafkaContainerTest class of org.testcontainers.containers package

Best Testcontainers-java code snippet using org.testcontainers.containers.KafkaContainerTest

Source:KafkaContainerTest.java

...34import static org.hamcrest.MatcherAssert.assertThat;35import static org.junit.jupiter.api.Assertions.*;36@DisplayName("Testing capabilities and usage of testcontainers KafkaContainer")37@Testcontainers38public class KafkaContainerTest {39    Logger logger = LoggerFactory.getLogger(KafkaContainerTest.class);40    public static Network kafkaNetwork = Network.newNetwork();41    @Container42    public static KafkaContainer kafka = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka").withTag("6.2.0-1-ubi8"))43            .withReuse(false)44            .withNetwork(kafkaNetwork)45            .withNetworkAliases("kafka");46    @Test47    public void kafkaUpTest(TestInfo testinfo) {48        logger.info("Test {} - started", testinfo.getDisplayName());49        kafka.start();50        assertTrue(kafka.isRunning());51        logger.info("Test {} - finished", testinfo.getDisplayName());52    }53    @Test...

KafkaContainerTest

Using AI Code Generation

1import org.testcontainers.containers.KafkaContainer2import org.testcontainers.containers.Network3import org.testcontainers.containers.output.Slf4jLogConsumer4import org.testcontainers.utility.DockerImageName5import org.slf4j.LoggerFactory6def network = Network.newNetwork()7def kafkaContainer = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:5.5.0"))8kafkaContainer.withNetwork(network)9kafkaContainer.withNetworkAliases("kafka")10kafkaContainer.start()11def logConsumer = new Slf4jLogConsumer(LoggerFactory.getLogger("Kafka"))12kafkaContainer.followOutput(logConsumer)13def bootstrapServer = kafkaContainer.getBootstrapServers()14def zookeeperContainer = kafkaContainer.getZookeeperContainer()15def zookeeperPort = zookeeperContainer.getMappedPort(2181)16def zookeeperHost = zookeeperContainer.getContainerIpAddress()17def brokerContainer = kafkaContainer.getKafkaBrokers().get(0)18def brokerPort = brokerContainer.getMappedPort(9092)19def brokerHost = brokerContainer.getContainerIpAddress()20def brokerContainer = kafkaContainer.getKafkaBrokers().get(0)21def brokerPort = brokerContainer.getMappedPort(9092)22def brokerHost = brokerContainer.getContainerIpAddress()23def brokerContainer = kafkaContainer.getKafkaBrokers().get(0)24def brokerPort = brokerContainer.getMappedPort(9092)25def brokerHost = brokerContainer.getContainerIpAddress()26def brokerContainer = kafkaContainer.getKafkaBrokers().get(0)27def brokerPort = brokerContainer.getMappedPort(9092)28def brokerHost = brokerContainer.getContainerIpAddress()29def brokerContainer = kafkaContainer.getKafkaBrokers().get(0)30def brokerPort = brokerContainer.getMappedPort(9092)31def brokerHost = brokerContainer.getContainerIpAddress()32def brokerContainer = kafkaContainer.getKafkaBrokers().get(0)33def brokerPort = brokerContainer.getMappedPort(9092)

KafkaContainerTest

Using AI Code Generation

1import org.testcontainers.containers.KafkaContainer;2import org.testcontainers.containers.Network;3import org.testcontainers.containers.wait.strategy.Wait;4import org.testcontainers.utility.DockerImageName;5import org.testcontainers.containers.output.Slf4jLogConsumer;6import java.io.IOException;7import java.util.concurrent.TimeoutException;8public class KafkaContainerTest {9    public static void main(String[] args) throws InterruptedException, IOException, TimeoutException {10        Network network = Network.newNetwork();11        KafkaContainer kafka = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:5.5.2"))12                .withNetwork(network)13                .withNetworkAliases("kafka")14                .waitingFor(Wait.forLogMessage(".*started.*", 1));15        kafka.start();16        Slf4jLogConsumer logConsumer = new Slf4jLogConsumer(logger);17        kafka.followOutput(logConsumer);18    }19}

KafkaContainerTest

Using AI Code Generation

1KafkaContainerTest kafkaContainerTest = new KafkaContainerTest();2kafkaContainerTest.start();3KafkaContainer kafkaContainer = new KafkaContainer();4kafkaContainer.start();5KafkaContainer kafkaContainer = new KafkaContainer("5.2.1");6kafkaContainer.start();7KafkaContainer kafkaContainer = new KafkaContainer("5.2.1");8kafkaContainer.withNetwork(Network.newNetwork());9kafkaContainer.start();10KafkaContainer kafkaContainer = new KafkaContainer("5.2.1");11kafkaContainer.withNetwork(Network.newNetwork());12kafkaContainer.withNetworkAliases("kafka");13kafkaContainer.start();14KafkaContainer kafkaContainer = new KafkaContainer("5.2.1");15kafkaContainer.withNetwork(Network.newNetwork());16kafkaContainer.withNetworkAliases("kafka");17kafkaContainer.withExposedPorts(9092);18kafkaContainer.start();19KafkaContainer kafkaContainer = new KafkaContainer("5.2.1");20kafkaContainer.withNetwork(Network.newNetwork());21kafkaContainer.withNetworkAliases("kafka");22kafkaContainer.withExposedPorts(9092);23kafkaContainer.start();24KafkaContainer kafkaContainer = new KafkaContainer("5.2.1");25kafkaContainer.withNetwork(Network.newNetwork());26kafkaContainer.withNetworkAliases("kafka");27kafkaContainer.withExposedPorts(9092);28kafkaContainer.withEnv("KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR", "1");29kafkaContainer.start();30KafkaContainer kafkaContainer = new KafkaContainer("5.2.1");31kafkaContainer.withNetwork(Network.newNetwork());32kafkaContainer.withNetworkAliases("kafka

KafkaContainerTest

Using AI Code Generation

1  1. import static org.junit.Assert.*;2  2. import static org.junit.Assume.assumeTrue;3  4. import java.util.Properties;4  6. import org.apache.kafka.clients.admin.AdminClient;5  7. import org.apache.kafka.clients.admin.AdminClientConfig;6  8. import org.apache.kafka.clients.admin.CreateTopicsResult;7  9. import org.apache.kafka.clients.admin.NewTopic;8 10. import org.apache.kafka.clients.consumer.ConsumerConfig;9 11. import org.apache.kafka.clients.consumer.ConsumerRecord;10 12. import org.apache.kafka.clients.consumer.ConsumerRecords;11 13. import org.apache.kafka.clients.consumer.KafkaConsumer;12 14. import org.apache.kafka.clients.producer.KafkaProducer;13 15. import org.apache.kafka.clients.producer.ProducerConfig;14 16. import org.apache.kafka.clients.producer.ProducerRecord;15 17. import org.apache.kafka.common.errors.TopicExistsException;16 18. import org.apache.kafka.common.serialization.StringDeserializer;17 19. import org.apache.kafka.common.serialization.StringSerializer;18 20. import org.junit.BeforeClass;19 21. import org.junit.ClassRule;20 22. import org.junit.Test;21 23. import org.testcontainers.containers.KafkaContainer;22 25. public class KafkaContainerTest {23 28.     public static KafkaContainer kafka = new KafkaContainer();24 30.     private static AdminClient adminClient;25 31.     private static KafkaConsumer<String, String> consumer;26 32.     private static KafkaProducer<String, String> producer;27 35.     public static void setUp() {28 36.         assumeTrue(JavaVersion.current().isJava8Compatible());29 38.         Properties adminClientConfig = new Properties();30 39.         adminClientConfig.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, kafka.getBootstrapServers());31 40.         adminClient = AdminClient.create(adminClientConfig);32 42.         Properties consumerConfig = new Properties();33 43.         consumerConfig.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, kafka.getBootstrapServers());34 44.         consumerConfig.put(ConsumerConfig.GROUP_ID_CONFIG, "test-group");

KafkaContainerTest

Using AI Code Generation

1import org.testcontainers.containers.KafkaContainerTest;2import org.testcontainers.containers.Network;3import org.testcontainers.containers.wait.strategy.Wait;4import org.testcontainers.utility.DockerImageName;5public class KafkaContainerTest {6    public static void main(String[] args) {7        try (KafkaContainerTest kafka = new KafkaContainerTest(DockerImageName.parse("confluentinc/cp-kafka:5.5.1"))) {8            kafka.withNetwork(Network.SHARED);9            kafka.withNetworkAliases("kafka");10            kafka.withExposedPorts(9092);11            kafka.waitingFor(Wait.forLogMessage(".*started.*", 1));12            kafka.start();13            System.out.println("Kafka started at " + kafka.getBootstrapServers());14        }15    }16}

KafkaContainerTest

Using AI Code Generation

1import java.util.Properties2import org.apache.kafka.clients.producer.{KafkaProducer, ProducerRecord}3import org.apache.kafka.clients.consumer.{ConsumerConfig, KafkaConsumer}4import org.apache.kafka.common.serialization.{StringDeserializer, StringSerializer}5import org.testcontainers.containers.KafkaContainer6import org.testcontainers.utility.DockerImageName7import scala.jdk.CollectionConverters._8object KafkaContainerTest {9  def main(args: Array[String]): Unit = {10    val kafkaContainer = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:6.1.0"))11    kafkaContainer.start()12    createTopic(bootstrapServers, topic)13    val producer = new KafkaProducer[String, String](producerProperties(bootstrapServers))14    val record = new ProducerRecord[String, String](topic, msg)15    producer.send(record)16    producer.flush()17    println("Message sent")18    val consumer = new KafkaConsumer[String, String](consumerProperties(bootstrapServers))19    consumer.subscribe(List(topic).asJava)20    val records = consumer.poll(1000)21    records.forEach(record => {22      println(s"Received message: ${record.value()}")23    })24    consumer.close()25    kafkaContainer.stop()26  }27  private def createTopic(bootstrapServers: String, topic: String): Unit = {28    import java.util.Properties29    import org.apache.kafka.clients.admin.{Admin, NewTopic}30    val adminClient = Admin.create(Map[String, Object](31    val topicDetails = new NewTopic(topic, 1, 1)32    adminClient.createTopics(List(topicDetails).asJava)33  }34  private def producerProperties(bootstrapServers: String): Properties = {35    val props = new Properties()36    props.put("bootstrap.servers", bootstrapServers)37    props.put("key.serializer", classOf[StringSerializer].getName)38    props.put("value.serializer", classOf[StringSerializer].getName)39  }40  private def consumerProperties(bootstrapServers: String): Properties = {41    val props = new Properties()42    props.put("bootstrap.servers", bootstrap

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.