[docs] Update Advanced Record Consuming

Use correct class instance JsonChangeConsumer in .notifiy in example code sinpshot Advanced Record Consuming  using Json data structure
This commit is contained in:
Ganesh Bankar 2024-07-12 17:55:32 +05:30 committed by Chris Cranford
parent 5603469755
commit f0dcbdb05e

View File

@ -441,7 +441,7 @@ class JsonChangeConsumer implements DebeziumEngine.ChangeConsumer<ChangeEvent<St
// Create the engine with this configuration ...
DebeziumEngine<ChangeEvent<String, String>> engine = DebeziumEngine.create(Json.class)
.using(props)
.notifying(new MyChangeConsumer())
.notifying(new JsonChangeConsumer())
.build();
----