From 2ba083719738dc6acb1a3a164aa447e033fb7537 Mon Sep 17 00:00:00 2001 From: Mickael Maison Date: Thu, 1 Dec 2022 18:07:54 +0100 Subject: [PATCH] MINOR: Fix compilation issue in FileStreamSourceConnector --- .../apache/kafka/connect/file/FileStreamSourceConnector.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSourceConnector.java b/connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSourceConnector.java index e732d55f81d7d..55090d889c99d 100644 --- a/connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSourceConnector.java +++ b/connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSourceConnector.java @@ -91,7 +91,7 @@ public ConfigDef config() { @Override public ExactlyOnceSupport exactlyOnceSupport(Map props) { AbstractConfig parsedConfig = new AbstractConfig(CONFIG_DEF, props); - filename = parsedConfig.getString(FILE_CONFIG); + String filename = parsedConfig.getString(FILE_CONFIG); // We can provide exactly-once guarantees if reading from a "real" file // (as long as the file is only appended to over the lifetime of the connector) // If we're reading from stdin, we can't provide exactly-once guarantees