This is a general thing; see
https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/dev/configuration/connector/
The python documentation isn't particularly clear on how to use Java
connectors. The easiest thing would be to use the "sql-*" connector jars
I guess.
On 08/11/2022
Ok thanks, will give that a try. Is that something that should be added to
the Kinesis connector docs page? There are existing instructions there for
adding the flink-connector-kinesis jar as a dependency, but no instructions
for adding commons-logging
Or if this is something more general, it
Said dependency (on commons-logging) is not meant to be provided by the
docker image, but bundled in your user-jar (along with the connector).
On 08/11/2022 02:14, Matt Fysh wrote:
Hi, I'm following the kinesis connector instructions as documented
here: