Expose option to enable `error_on_callbacks` in `KafkaProducer.send`
Open
producer
- Dominant language
- Python
- Stars
- 5.9k
- Forks
- 1.5k
- Avg merge
- 3d 11h
- Merged PRs (30d)
- 3
Description
With `Future.error_on_callbacks == False`, the default, errors raised in callbacks are suppressed (even critical ones like `MemoryError`). The only feasible way to change this behavior is currently to override the class attribute, but this has global effects and might not be possible in a large application with multiple usages and different needs. I'm proposing to change this class attribute to an instance attribute, and expose a way to change its value, either through instantiation of `KafkaProducer`, or by passing a parameter to `.send()`.
Contributor guide
No contributing guide indexed for this repository
Assessment
This issue has not been assessed yet.