Add num of tries while pushing to kafka
Aberta
- Linguagem predominante
- Python
- Estrelas
- 13
- Forks
- 2
- Métricas de merge de PRs
- Nenhum PR com merge em 30d
Descrição
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
Guia de contribuição
Avaliação
Esta issue ainda não foi avaliada.