datahub
datahub copied to clipboard
lineage_emitter_kafka.py connection refused
Describe the bug When I tried to run lineage_emitter_kafka.py result is connection refused. Broker is located on port 29092, I tried with public IP/localhost but no change when I tried with default value "broker" it can't solve the naming says: "Failed to resolve 'broker:29092". Port is already open on firewall. Datahub runs with Docker and everything is located on Azure VM.
To Reproduce Steps to reproduce the behavior:
- Download the script from here https://raw.githubusercontent.com/datahub-project/datahub/master/metadata-ingestion/examples/library/lineage_emitter_kafka.py
- Open file with nano and change the "broker" and "schema-registry" parts with yours
- Run script with python3
Expected behavior Script will run without error.
Screenshots
Desktop (please complete the following information):
- OS: Linux 20.04
- Browser: Edge
- Version latest
Additional context None.
I changed the config and now it is working. Solution is changing schema_registry url and bootstrap with your publicIP.