You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
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().
The text was updated successfully, but these errors were encountered:
With
Future.error_on_callbacks == False
, the default, errors raised in callbacks are suppressed (even critical ones likeMemoryError
). 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 ofKafkaProducer
, or by passing a parameter to.send()
.The text was updated successfully, but these errors were encountered: