debezium-embedded.core — nyampass/debezium-embedded 0.2.2-SNAPSHOT

create-always-offset-commit-policy clj

(create-always-offset-commit-policy)

create-batch-consumer clj

(create-batch-consumer f)

create-completion-callback clj

(create-completion-callback f)

Handle the completion of the embedded connector engine.

create-configuration clj

(create-configuration m)

create-connector-callback clj

(create-connector-callback f)

Callback function which informs users about the various stages a connector goes through during startup.

create-engine clj

(create-engine {:keys [config consumer] :as options})

create-periodic-offset-commit-policy clj

(create-periodic-offset-commit-policy x)

mark-processed! clj

(mark-processed! committer record)