Skip to content

Commit a693b52

Browse files
committed
fix(plugin): fix FilePulseSourceConnector should raise an error when FileSystemMonitorThread crash
1 parent c6f1f13 commit a693b52

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

connect-file-pulse-plugin/src/main/java/io/streamthoughts/kafka/connect/filepulse/source/FilePulseSourceConnector.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -129,7 +129,7 @@ public void start(final Map<String, String> props) {
129129
fsMonitorThread = new FileSystemMonitorThread(context, monitor, connectorConfig.getListingInterval());
130130
fsMonitorThread.setUncaughtExceptionHandler((t, e) -> {
131131
LOG.info("Uncaught error from file system monitoring thread [{}]", t.getName(), e);
132-
throw new ConnectException(e);
132+
context.raiseError(new ConnectException("Unexpected error from FileSystemMonitorThread", e));
133133
});
134134
fsMonitorThread.start();
135135
LOG.info("Started FilePulse source connector: {}", connectorGroupName);

0 commit comments

Comments
 (0)