I have an Airflow DAG calling a kafka-python producer. I am getting the error below trying to send a message from the Airflow container to the Kafka container.
I am using Docker Desktop 3.3.3 on a macbook pro. Airflow and Kafka are in separate docker container apps. Both container apps are using the same docker network, which is specified in the compose files:
I have an Airflow DAG calling a kafka-python producer. I am getting the error below trying to send a message from the Airflow container to the Kafka container.
I am using Docker Desktop 3.3.3 on a macbook pro. Airflow and Kafka are in separate docker container apps. Both container apps are using the same docker network, which is specified in the compose files:
I am able to connect to the Kafka container using the conduktor client on my mac pointing to 127.0.0.1:9092
Here is the error message I see in Airflow:
Here is the Kafka compose file:
Here is the kafka-python code: