We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent cb5c5c0 commit a0a071cCopy full SHA for a0a071c
flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/KafkaUtil.java
@@ -67,7 +67,6 @@ public static KafkaContainer createKafkaContainer(String containerName) {
67
.withEnv("KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR", "1")
68
.withEnv("KAFKA_TRANSACTION_STATE_LOG_MIN_ISR", "1")
69
.withEnv("KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR", "1")
70
- .withEnv("KAFKA_CONFLUENT_SUPPORT_METRICS_ENABLE", "false")
71
.withEnv("KAFKA_LOG4J_ROOT_LOGLEVEL", logLevel)
72
.withEnv("KAFKA_LOG4J_LOGGERS", "state.change.logger=" + logLevel)
73
.withEnv("KAFKA_CONFLUENT_SUPPORT_METRICS_ENABLE", "false")
0 commit comments