hey, is there a way to pull lineage information from Kafka Sources and Sinks? We just want to know what kafka clusters and topics a specific job is writing and reading from.

I think it is not available in Flink out of the box and some custom layer is required, via libraries or instrumentation