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 <[email protected]>
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 <[email protected]>
---
.../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
