Replace confluentinc/cp-kafka with apache/kafka-native

[helpermethod]

What problem are you trying to solve?

• replace org.testcontainers.container.KafkaContainer with the new implementation org.testcontainers.kafka.KafkaContainer
• replace the Confluent Kafka Image with the much faster Apache Kafka Native Image

What precondition(s) should be checked before applying this recipe?

Requires Testcontainers 1.20.1

Describe the situation before applying the recipe

import org.testcontainers.containers.KafkaContainer;

@TestContainers
class KafkaTests {
    @Container
    KafkaContainer kafka = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:7.5.3"));
}

Describe the situation after applying the recipe

import org.testcontainers.kafka.KafkaContainer;

@TestContainers
class KafkaTests {
    @Container
    KafkaContainer kafka = new KafkaContainer(DockerImageName.parse("apache/kafka-native:3.8.0"));
}

Have you considered any alternatives or workarounds?

No.

Any additional context

Docker image versions don't map 1:1.

Are you interested in contributing this recipe to OpenRewrite?

Yes!

[timtebeek]

Thanks for logging an issue @helpermethod ! I'd been thinking of doing the same after doing this manually once before:

• Switch to apache/kafka-native:3.8.0 timtebeek/kafka-dead-letter-publishing#58

As seen there we could even remove the DockerImageName.parse, which might make a neat recipe in and of itself.

In terms of implementation we can reuse ChangeType; then we have to match the argument going into KafkaContainer, and in there any argument going into DockerImageName.parse to switch over to the new base image. Thanks for offering to help! Let us know if you'd need any more guidance.