[flink] branch master updated: [FLINK-24119][Connector/Kafka] Set offsets.topic.replication.factor to 1. This closes #21190

[martijnvisser]

This is an automated email from the ASF dual-hosted git repository.

martijnvisser pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new f73189ddf5a [FLINK-24119][Connector/Kafka] Set 
offsets.topic.replication.factor to 1. This closes #21190
f73189ddf5a is described below

commit f73189ddf5ae0457592ed1bf74b3d68f7c883655
Author: Mason Chen <mas.c...@berkeley.edu>
AuthorDate: Mon Oct 31 01:14:30 2022 -0700

    [FLINK-24119][Connector/Kafka] Set offsets.topic.replication.factor to 1. 
This closes #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
---
 .../java/org/apache/flink/connector/kafka/testutils/KafkaUtil.java     | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/KafkaUtil.java
 
b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/KafkaUtil.java
index 0d5d105f577..267f7c7c894 100644
--- 
a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/KafkaUtil.java
+++ 
b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/KafkaUtil.java
@@ -89,11 +89,10 @@ public class KafkaUtil {
         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",