[Bug]: Failed to start with confluentinc/cp-kafka:latest

[Discordia]

Module

Core

Testcontainers version

1.21.1

Using the latest Testcontainers version?

Yes

Host OS

Linux

Host Arch

amd64

Docker version

Client: Docker Engine - Community
 Version:           27.0.3
 API version:       1.46
 Go version:        go1.21.11
 Git commit:        7d4bcd8
 Built:             Sat Jun 29 00:02:29 2024
 OS/Arch:           linux/amd64
 Context:           default

Server: Docker Engine - Community
 Engine:
  Version:          27.0.3
  API version:      1.46 (minimum version 1.24)
  Go version:       go1.21.11
  Git commit:       662f78c
  Built:            Sat Jun 29 00:02:29 2024
  OS/Arch:          linux/amd64
  Experimental:     false
 containerd:
  Version:          1.7.18
  GitCommit:        ae71819c4f5e67bb4d5ae76a6b735f29cc25774e
 runc:
  Version:          1.7.18
  GitCommit:        v1.1.13-0-g58aa920
 docker-init:
  Version:          0.19.0
  GitCommit:        de40ad0

What happened?

Kafka docker container failed to start. It looks like there has just been a new one with a new major version 8.0.0.

Relevant log output

java.lang.ExceptionInInitializerError

  Caused by: java.util.concurrent.ExecutionException: org.testcontainers.containers.ContainerLaunchException: Container startup failed for image confluentinc/cp-kafka:latest

  Caused by: org.testcontainers.containers.ContainerLaunchException: Container startup failed for image confluentinc/cp-kafka:latest

  Caused by: org.rnorth.ducttape.RetryCountExceededException: Retry limit hit with exception

  Caused by: org.testcontainers.containers.ContainerLaunchException: Could not create/start container

  Caused by: java.lang.IllegalStateException: Wait strategy failed. Container exited with code 1

  Caused by: org.testcontainers.containers.ContainerLaunchException: Timed out waiting for log output matching '.*[KafkaServer id=d+] started.*'

Additional Information

No response

[eddumelendez]

Can you share your code, please? and the import for KafkaContainer

[Discordia]

Not exactly sure what you are after, but it looks like this:

import org.testcontainers.containers.KafkaContainer;
import org.testcontainers.utility.DockerImageName;

            DockerImageName image = DockerImageName.parse("confluentinc/cp-kafka");
            kafka = new KafkaContainer(image);
            kafka.start();

[Discordia]

Downgrading to 7.9.1 worked around the issue.

[eddumelendez]

Not exactly sure what you are after

Understand what the user is doing in order to provide an answer.

1. It is recommended to use a fixed version. You can use "confluentinc/cp-kafka:8.0.0". The suggestion is to use the very same version used in production.
2. If you are still using org.testcontainers.containers.KafkaContainer then add withKraft(). E.g: new KafkaContainer(image).withKraft()
3. You can switch to ConfluentKafkaContainer because org.testcontainers.containers.KafkaContainer is already deprecated.

Following step 1 and 2 or 3 would fix your issue.

[Discordia]

Ok thanks, yes we have switched to using a fixed version. We will try out 3 also to move to ConfluentKafkaContainer.