Install & Compatibility
Where this runs
No compatibility data collected yet for this library.
Code
Verified usage
Verified import paths — ran on the pinned version, not inferred.
EmbeddedEngine
✓ io.debezium.embedded.EmbeddedEngine
Starts an embedded Debezium engine to capture changes from a MySQL database.
import io.debezium.embedded.EmbeddedEngine;
import io.debezium.config.Configuration;
public class Example {
public static void main(String[] args) {
Configuration config = Configuration.create()
.with("connector.class", "io.debezium.connector.mysql.MySqlConnector")
.with("offset.storage", "org.apache.kafka.connect.storage.FileOffsetBackingStore")
.with("offset.storage.file.filename", "/tmp/offsets.dat")
.with("offset.flush.interval.ms", 60000)
.with("database.hostname", "localhost")
.with("database.port", 3306)
.with("database.user", "debezium")
.with("database.password", "dbz")
.with("database.server.id", 85744)
.with("database.server.name", "my-app-connector")
.with("database.include.list", "inventory")
.with("database.history", "io.debezium.relational.history.FileDatabaseHistory")
.with("database.history.file.filename", "/tmp/dbhistory.dat")
.build();
EmbeddedEngine engine = EmbeddedEngine.create()
.using(config)
.notifying(record -> System.out.println(record))
.build();
engine.run();
}
}
Audit
Dependencies
No dependency data recorded yet.