Exit when backupsink stopped

discanto · discanto · commit b9c1cfe2e351 · 2020-08-10T14:21:51.000+02:00
diff --git a/src/main/java/de/azapps/kafkabackup/sink/BackupSinkTask.java b/src/main/java/de/azapps/kafkabackup/sink/BackupSinkTask.java
@@ -206,6 +206,7 @@ public void stop() {
             }
             offsetSink.close();
             log.info("Stopped BackupSinkTask");
+            exitFunction.accept(0);
         } catch (IOException e) {
             throw new RuntimeException(e);
         }

Original file line number	Diff line number	Diff line change
`@@ -206,6 +206,7 @@ public void stop() {`
`206`	`206`	`}`
`207`	`207`	`offsetSink.close();`
`208`	`208`	`log.info("Stopped BackupSinkTask");`
	`209`	`+ exitFunction.accept(0);`
`209`	`210`	`} catch (IOException e) {`
`210`	`211`	`throw new RuntimeException(e);`
`211`	`212`	`}`