I’m a beginner with kafka. Deployed kafka and airflow inside docker container. My airflow dag seems to be running correctly. I tried to send messages to kafka but when I use kafka console consumer, it outputted nothing.