BAEL-9420: Add Testcontainer Podman Test

testing-modules/pom.xml

@@ -75,6 +75,7 @@
         <module>mockito-3</module>
         <module>mockito-4</module>
         <module>gatling-java</module>
+        <module>test-containers-podman</module>
     </modules>
 
 </project>

testing-modules/test-containers-podman/pom.xml

@@ -0,0 +1,129 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <parent>
+        <groupId>com.baeldung</groupId>
+        <artifactId>testing-modules</artifactId>
+        <version>1.0.0-SNAPSHOT</version>
+    </parent>
+
+    <artifactId>test-containers-podman</artifactId>
+    <version>1.0-SNAPSHOT</version>
+    <name>test-containers-podman</name>
+    <description>Test Containers Using Podman</description>
+    <packaging>jar</packaging>
+
+    <properties>
+        <testcontainers.version>2.0.1</testcontainers.version>
+        <redis.testcontainers.version>2.2.4</redis.testcontainers.version>
+    </properties>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.testcontainers</groupId>
+            <artifactId>testcontainers</artifactId>
+            <version>${testcontainers.version}</version>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.testcontainers</groupId>
+            <artifactId>junit-jupiter</artifactId>
+            <version>1.21.3</version>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.testcontainers</groupId>
+            <artifactId>testcontainers-mysql</artifactId>
+            <version>${testcontainers.version}</version>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.testcontainers</groupId>
+            <artifactId>kafka</artifactId>
+            <version>1.21.3</version>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>com.redis</groupId>
+            <artifactId>testcontainers-redis</artifactId>
+            <version>${redis.testcontainers.version}</version>
+            <scope>test</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>redis.clients</groupId>
+            <artifactId>jedis</artifactId>
+            <version>5.1.0</version>
+            <scope>test</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>org.junit.jupiter</groupId>
+            <artifactId>junit-jupiter-engine</artifactId>
+            <version>5.10.2</version>
+            <scope>test</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>com.mysql</groupId>
+            <artifactId>mysql-connector-j</artifactId>
+            <version>9.5.0</version>
+            <scope>test</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>org.apache.kafka</groupId>
+            <artifactId>kafka-clients</artifactId>
+            <version>3.6.1</version>
+            <scope>test</scope>
+        </dependency>
+
+    </dependencies>
+
+    <build>
+        <resources>
+            <resource>
+                <directory>src/test/resources</directory>
+                <filtering>true</filtering>
+            </resource>
+        </resources>
+
+        <plugins>
+            <!-- Unit tests -->
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-surefire-plugin</artifactId>
+                <configuration>
+                    <environmentVariables>
+                        <!-- Podman socket in rootless mode -->
+                        <DOCKER_HOST>unix://${env.XDG_RUNTIME_DIR}/podman/podman.sock</DOCKER_HOST>
+                        <TESTCONTAINERS_RYUK_DISABLED>true</TESTCONTAINERS_RYUK_DISABLED>
+                    </environmentVariables>
+                </configuration>
+            </plugin>
+
+            <!-- Integration tests (if you use Failsafe) -->
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-failsafe-plugin</artifactId>
+                <configuration>
+                    <environmentVariables>
+                        <DOCKER_HOST>unix://${env.XDG_RUNTIME_DIR}/podman/podman.sock</DOCKER_HOST>
+                        <TESTCONTAINERS_RYUK_DISABLED>true</TESTCONTAINERS_RYUK_DISABLED>
+                    </environmentVariables>
+                </configuration>
+            </plugin>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <configuration>
+                    <source>9</source>
+                    <target>9</target>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
+</project>

testing-modules/test-containers-podman/src/test/java/com.baeldung.testcontainers.podman/KafkaLiveTest.java

@@ -0,0 +1,58 @@
+package com.baeldung.testcontainers.podman;
+
+import org.apache.kafka.clients.consumer.ConsumerConfig;
+import org.apache.kafka.clients.consumer.ConsumerRecord;
+import org.apache.kafka.clients.consumer.ConsumerRecords;
+import org.apache.kafka.clients.consumer.KafkaConsumer;
+import org.apache.kafka.clients.producer.KafkaProducer;
+import org.apache.kafka.clients.producer.ProducerConfig;
+import org.apache.kafka.clients.producer.ProducerRecord;
+import org.apache.kafka.common.serialization.StringDeserializer;
+import org.apache.kafka.common.serialization.StringSerializer;
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Test;
+import org.testcontainers.containers.KafkaContainer;
+import org.testcontainers.utility.DockerImageName;
+
+import java.time.Duration;
+import java.util.Collections;
+import java.util.Properties;
+
+public class KafkaLiveTest {
+
+    @Test
+    void whenProducingMessage_thenConsumerReceivesIt() {
+        DockerImageName image = DockerImageName.parse("confluentinc/cp-kafka:7.6.1");
+        try (KafkaContainer kafka = new KafkaContainer(image)) {
+            kafka.start();
+
+            String bootstrap = kafka.getBootstrapServers();
+            String topic = "hello";
+
+            Properties prodProps = new Properties();
+            prodProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrap);
+            prodProps.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
+            prodProps.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
+
+            try (KafkaProducer<String, String> producer = new KafkaProducer<>(prodProps)) {
+                producer.send(new ProducerRecord<>(topic, "key", "hello")).get();
+            } catch (Exception e) {
+                throw new RuntimeException(e);
+            }
+
+            Properties consProps = new Properties();
+            consProps.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrap);
+            consProps.put(ConsumerConfig.GROUP_ID_CONFIG, "test-group");
+            consProps.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");
+            consProps.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
+            consProps.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
+
+            try (KafkaConsumer<String, String> consumer = new KafkaConsumer<>(consProps)) {
+                consumer.subscribe(Collections.singletonList(topic));
+                ConsumerRecords<String, String> records = consumer.poll(Duration.ofSeconds(10));
+                ConsumerRecord<String, String> first = records.iterator().next();
+                Assertions.assertEquals("hello", first.value());
+            }
+        }
+    }
+}

testing-modules/test-containers-podman/src/test/java/com.baeldung.testcontainers.podman/MysqlLiveTest.java

@@ -0,0 +1,32 @@
+package com.baeldung.testcontainers.podman;
+
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Test;
+import org.testcontainers.mysql.MySQLContainer;
+
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.ResultSet;
+import java.sql.Statement;
+
+class MysqlLiveTest {
+
+    @Test
+    void whenQueryingDatabase_thenReturnsOne() throws Exception {
+
+        try (MySQLContainer mysql = new MySQLContainer("mysql:8.4")) {
+            mysql.start();
+
+            try (Connection conn = DriverManager.getConnection(
+                    mysql.getJdbcUrl(), mysql.getUsername(), mysql.getPassword());
+                 Statement st = conn.createStatement()) {
+
+                st.execute("CREATE TABLE t(id INT PRIMARY KEY)");
+                st.execute("INSERT INTO t VALUES (1)");
+                ResultSet rs = st.executeQuery("SELECT COUNT(*) FROM t");
+                rs.next();
+                Assertions.assertEquals(1, rs.getInt(1));
+            }
+        }
+    }
+}

testing-modules/test-containers-podman/src/test/java/com.baeldung.testcontainers.podman/RedisLiveTest.java

@@ -0,0 +1,26 @@
+package com.baeldung.testcontainers.podman;
+
+
+import com.redis.testcontainers.RedisContainer;
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Test;
+import redis.clients.jedis.Jedis;
+
+class RedisLiveTest {
+
+    @Test
+    void whenSettingValue_thenCanGetItBack() {
+        try (RedisContainer redis = new RedisContainer("redis:7-alpine").withExposedPorts(6379)) {
+            redis.start();
+
+            String host = redis.getHost();
+            int port = redis.getFirstMappedPort();
+
+            try (Jedis jedis = new Jedis(host, port)) {
+                jedis.set("greeting", "hello");
+                String value = jedis.get("greeting");
+                Assertions.assertEquals("hello", value);
+            }
+        }
+    }
+}