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",