Add num of tries while pushing to kafka
Open
- Dominant language
- Python
- Stars
- 13
- Forks
- 2
- PR merge metrics
- No merged PRs in 30d
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
Contributor guide
Assessment
This issue has not been assessed yet.