I'm struggling to grok the difference between pipeline connectors
<https://nightlies.apache.org/flink/flink-cdc-docs-release-3.2/docs/connectors/pipeline-connectors/overview/>
and Flink sources
<https://nightlies.apache.org/flink/flink-cdc-docs-release-3.2/docs/connectors/flink-sources/overview/>
in
Flink CDC.

I understand pipeline connectors, and have been through the quickstart and
they make sense.

But how are Flink sources any different from what I'd build in Flink SQL
itself directly? How do they fit into Flink CDC? Or is the point that Flink
CDC provides CDC connectors, and they are documented here
<https://nightlies.apache.org/flink/flink-cdc-docs-release-3.2/docs/connectors/flink-sources/overview/>
when they could as logically be documented here
<https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/table/overview/>
under
the main Flink docs?

Thanks in advance,
Robin

Reply via email to