Skip to content

Instantly share code, notes, and snippets.

@PatrickGotthard
PatrickGotthard / Application.java
Last active January 18, 2023 11:36
Debezium Error Handling
package debezium;
import java.io.IOException;
import java.time.Duration;
import java.util.Properties;
import java.util.concurrent.Executor;
import java.util.concurrent.Executors;
import org.apache.kafka.connect.storage.FileOffsetBackingStore;
import org.springframework.boot.SpringApplication;