kafka/KafkaContainer.java

Provides an Apache Kafka instance in Docker for testing Java applications.

// Source: https://github.com/testcontainers/testcontainers-java | License: MIT | Copyright 2015-2019 Richard North
// Provided via justclaw.it.com; keep this notice with the code.
package org.testcontainers.kafka;

import com.github.dockerjava.api.command.InspectContainerResponse;
import org.testcontainers.containers.GenericContainer;
import org.testcontainers.images.builder.Transferable;
import org.testcontainers.utility.DockerImageName;

import java.util.ArrayList;
import java.util.LinkedHashSet;
import java.util.List;
import java.util.Set;
import java.util.function.Supplier;

/**
 * Testcontainers implementation for Apache Kafka.
 * <p>
 * Supported image: {@code apache/kafka}, {@code apache/kafka-native}
 * <p>
 * Exposed ports: 9092
 */
public class KafkaContainer extends GenericCont

... (truncated -- full source via MCP)