티스토리 뷰

공부

[Airflow] kafka producer flush() not working (solution: instanciate object in execute)

승가비 2022. 5. 7. 18:46
728x90

https://github.com/confluentinc/confluent-kafka-python/issues/1122

 

Flush() call getting stuck inside celery task no messages being produced. · Issue #1122 · confluentinc/confluent-kafka-python

Description Unable to publish messages when using the library inside a celery worker in airflow. Here is the debug information coming from the librdkafka lib on the worker logs. We are following th...

github.com

728x90
저작자표시 비영리

'공부' 카테고리의 다른 글

[Python] __new__ return constructor  (0) 2022.05.07
[K8s] Ingress  (0) 2022.05.07
[docker-compose] `docker-compose -f docker-compose.yml up`  (0) 2022.05.07
[yaml] multiple lines (except `\n`)  (0) 2022.05.07
[Java] url unescape `URLDecoder.decode(url)`  (0) 2022.05.07
댓글