Aleksandr Savonin created FLINK-38937:
-----------------------------------------
Summary: 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
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)
