This is an automated email from the ASF dual-hosted git repository. fanrui pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/flink-connector-kafka.git
commit a0a071cbda258b329deba0725a5a8f93f80b8a29 Author: Aleksandr Savonin <[email protected]> AuthorDate: Mon Nov 10 18:53:23 2025 +0100 [hotfix] Remove redundant env var in KafkaUtil --- .../test/java/org/apache/flink/connector/kafka/testutils/KafkaUtil.java | 1 - 1 file changed, 1 deletion(-) diff --git a/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/KafkaUtil.java b/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/KafkaUtil.java index 78b344b6..1b4bf77c 100644 --- a/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/KafkaUtil.java +++ b/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/KafkaUtil.java @@ -67,7 +67,6 @@ public class KafkaUtil { .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_CONFLUENT_SUPPORT_METRICS_ENABLE", "false")
