[kafka] branch trunk updated: MINOR: Fix compilation issue in FileStreamSourceConnector (#12938)

[jgus]

This is an automated email from the ASF dual-hosted git repository.

jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 8bb89c4beb6 MINOR: Fix compilation issue in FileStreamSourceConnector 
(#12938)
8bb89c4beb6 is described below

commit 8bb89c4beb6c21558bff6207dfa5f68729ac51bc
Author: Mickael Maison <mimai...@users.noreply.github.com>
AuthorDate: Thu Dec 1 22:01:12 2022 +0100

    MINOR: Fix compilation issue in FileStreamSourceConnector (#12938)
    
    Fix compilation failure introduced in 
https://github.com/apache/kafka/pull/12355.
    
    Reviewers: Mickael Maison <mickael.mai...@gmail.com>
---
 .../java/org/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 e732d55f81d..55090d889c9 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 class FileStreamSourceConnector extends 
SourceConnector {
     @Override
     public ExactlyOnceSupport exactlyOnceSupport(Map<String, String> 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