[
https://issues.apache.org/jira/browse/FLINK-38937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Paul reassigned FLINK-38937:
-----------------------------------
Assignee: Aleksandr Savonin
> Introduce TestKafkaContainer to support Confluent and official Apache Kafka
> images with KRaft
> ---------------------------------------------------------------------------------------------
>
> Key: FLINK-38937
> URL: https://issues.apache.org/jira/browse/FLINK-38937
> Project: Flink
> Issue Type: Improvement
> Components: Connectors / Kafka
> Reporter: Aleksandr Savonin
> Assignee: Aleksandr Savonin
> Priority: Major
>
> The {{org.testcontainers.{*}containers{*}.KafkaContainer}} class currently
> used in Flink Kafka connector tests has been deprecated. The recommended
> replacement requires different container classes based on the Kafka
> distribution:
> * {{org.testcontainers.{*}kafka{*}.KafkaContainer}} for Apache Kafka images.
> * {{ConfluentKafkaContainer}} for Confluent Platform images.
> Both of these implementations support KRaft mode.
> This change introduces a {{TestKafkaContainer}} wrapper that automatically
> selects the appropriate container implementation, enabling:
> 1. Migration away from the deprecated Testcontainers {{{}KafkaContainer{}}}.
> 2. Support for both Apache Kafka and Confluent Platform images.
> 3. KRaft mode support, eliminating the Zookeeper dependency and reducing
> resource overhead.
> 4. Future flexibility to use official Apache Kafka images as an alternative
> to Confluent-specific images.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
