kafka

library1.21.4javamavenunverified

Provides isolated Kafka container management for Java code testing using Testcontainers.

<dependency>
  <groupId>org.testcontainers</groupId>
  <artifactId>kafka</artifactId>
  <version>1.21.4</version>
</dependency>

github ↗homepage ↗docs ↗

INSTALL

IMPORT

SIG · KAFKA

kafka

testingjavav1.21.4

harness data pending

Install & Compatibility

Where this runs

No compatibility data collected yet for this library.

Code

Verified usage

Verified import paths — ran on the pinned version, not inferred.

KafkaContainer

✓ org.testcontainers.containers.KafkaContainer

Starts a Kafka container and retrieves the bootstrap servers.

import org.testcontainers.containers.KafkaContainer; import org.testcontainers.utility.DockerImageName; public class KafkaTest { public static void main(String[] args) { try (KafkaContainer kafka = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:latest"))) { kafka.start(); String bootstrapServers = kafka.getBootstrapServers(); System.out.println("Bootstrap servers: " + bootstrapServers); } } }

Debug

Known issues

gotchaTestcontainers requires Docker to be installed and running.

fix

Ensure Docker is installed and the Docker daemon is running before executing tests.

affects: all

Upgrade

Version history

1.21.4latest on Maven

Audit

Dependencies

No dependency data recorded yet.

Agent activity

7 hits · last 30 days

node

Resources

githubhttps://github.com/testcontainers/testcontainers-java ↗

homepagehttps://java.testcontainers.org ↗

docshttps://appdoc.app/artifact/org.testcontainers/kafka/ ↗