티스토리 뷰
공부
[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 |
[Airflow] kafka producer flush() not working (solution: instanciate object in execute) (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 |
댓글
250x250
공지사항
최근에 올라온 글
최근에 달린 댓글
- Total
- 142,688
- Today
- 14
- Yesterday
- 219
TAG
- 개리마커스
- 클루지
- 연애학개론
- Bot
- follower
- wlw
- 어떻게 능력을 보여줄 것인가?
- 인스타그램
- 김달
- COUNT
- Kluge
- 유투브
- 책그림
- 팔로워 수 세기
- 메디파크 내과 전문의 의학박사 김영수