티스토리 뷰
공부
[Airflow] kafka producer flush() not working (solution: instanciate object in execute)
승가비 2022. 5. 7. 18:46728x90
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 |
댓글