dpkp / dpkp/kafka-python

Expose option to enable `error_on_callbacks` in `KafkaProducer.send`

Open
#2,366 0 comments 0 reactions 0 assignees View on GitHub
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.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.