diff --git a/documentation/modules/ROOT/pages/development/engine.adoc b/documentation/modules/ROOT/pages/development/engine.adoc index 97ff1d88d..08587b927 100644 --- a/documentation/modules/ROOT/pages/development/engine.adoc +++ b/documentation/modules/ROOT/pages/development/engine.adoc @@ -441,7 +441,7 @@ class JsonChangeConsumer implements DebeziumEngine.ChangeConsumer> engine = DebeziumEngine.create(Json.class) .using(props) - .notifying(new MyChangeConsumer()) + .notifying(new JsonChangeConsumer()) .build(); ----