Add num of tries while pushing to kafka
Ouverte
- Langage dominant
- Python
- Étoiles
- 13
- Forks
- 2
- Métriques de merge des PR
- Aucune PR mergée en 30 j
Description
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
Guide de contribution
Ouvrir le guide de contribution
Évaluation
Cette issue n'a pas encore été évaluée.