Add num of tries while pushing to kafka
未关闭
- 主要语言
- Python
- 星标
- 13
- 派生
- 2
- PR 合并指标
- 30 天内没有已合并 PR
描述
As of now, we are pushing to Kafka via an infinite loop, which might cause problems in the future.
We should consider defining "number of tries" after which exception will be raised.
https://github.com/AbsaOSS/py2k/blob/dfe8d5e8e77fa65fc3ce486845397fc92ea22673/py2k/producer.py#L24-L39
贡献指南
评估
这个 Issue 还没有评估数据。