You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fa...@apache.org on 2025/11/10 18:57:39 UTC
(flink-connector-kafka) 01/02: [hotfix] Remove redundant env var in KafkaUtil
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 <sa...@gmail.com>
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")