ape_dts supports two consumer modes:
-
ape_dts extracts snapshot/increment data from MySQL/Postgres, sends it to Kafka in avro format. Users can consume it through Kafka clients.
-
ape_dts starts as an HTTP server, extracts snapshot/increment data from MySQL/Postgres and caches it in memory. Users can pull and consume the data in avro format through HTTP APIs.