Hey team, i am not able to ingest airflow metadata to datahub via datahub_kafka_default, its not throwing any error to me even if give wrong bootstrap url, My config file and log file:

Hi @limited-forest-73733 Did you register the source as per step 3 in doc: https://datahubproject.io/docs/lineage/airflow#setup

Yeah there is an issue in kafka sink, we are not calling flush method. I can see having open PR to fix it

Hi @limited-forest-73733 Which PR are you referring to ? I haven't find any sink PR at DataHub github

It has been merged