Add num of tries while pushing to kafka
Aperta
- Lingua principale
- Python
- Stelle
- 13
- Fork
- 2
- Metriche di merge delle PR
- Nessuna PR unita negli ultimi 30g
Descrizione
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
Guida per i contributori
Apri la guida per i contributori
Valutazione
Questa issue non è ancora stata valutata.