[FLINK-24119][Connector/Kafka] Set offsets.topic.replication.factor t…

…o 1. This closes apache#21190 Confluent's documentation on default configurations states that this setting should be applied for a single container environment. This should help with the test stability of FLINK-24119
liuyongvs · Oct 31, 2022 · f73189d · f73189d
1 parent cd98b80
commit f73189d
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...k-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/KafkaUtil.java b/...k-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/KafkaUtil.java
@@ -89,11 +89,10 @@ public static KafkaContainer createKafkaContainer(
         return new KafkaContainer(DockerImageName.parse(dockerImageVersion))
                 .withEnv("KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR", "1")
                 .withEnv("KAFKA_TRANSACTION_STATE_LOG_MIN_ISR", "1")
+                .withEnv("KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR", "1")
                 .withEnv("KAFKA_CONFLUENT_SUPPORT_METRICS_ENABLE", "false")
                 .withEnv("KAFKA_LOG4J_ROOT_LOGLEVEL", logLevel)
                 .withEnv("KAFKA_LOG4J_LOGGERS", "state.change.logger=" + logLevel)
-                .withEnv("KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR", "1")
-                .withEnv("KAFKA_TRANSACTION_STATE_LOG_MIN_ISR", "1")
                 .withEnv("KAFKA_CONFLUENT_SUPPORT_METRICS_ENABLE", "false")
                 .withEnv(
                         "KAFKA_TRANSACTION_MAX_TIMEOUT_MS",