Expose option to enable `error_on_callbacks` in `KafkaProducer.send`
Nadie ha tomado este issue todavía.
- #3073 de @wgu9 — cerrado sin fusionar
Evaluación
- Dificultad
- 5/5
- Tiempo estimado
- Más de una semana
- Aptitud para principiantes
- 35/100
- Tipo de issue
- Nueva funcionalidad
- Claridad
- Bastante claro
- Estado de actividad
- Estancado
- Stack tecnológico
- kafka, python
Línea de trabajo
Empieza leyendo KafkaProducer.send y el comportamiento de Future.error_on_callbacks descrito en el issue. Compara la configuración a nivel de instancia y a nivel de envío, luego define la API pública y verifica que los errores de callback puedan controlarse de forma independiente para distintos usos del producer sin cambiar el comportamiento predeterminado.
Escrito por el modelo de indexación a partir del texto del issue.
Descripción
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().
- Lenguaje dominante
- Python
- Estrellas
- 5.9k
- Forks
- 1.5k
- Métricas de merge de PR
- Sin PR fusionados en 30 d
Preparar el entorno
Este proyecto no incluye contenedor de desarrollo, Dockerfile ni guía de contribución, así que la configuración corre por tu cuenta: empieza por su README y consulta nuestra guía para la primera contribución para los pasos generales.
Primeros pasos
- Lee el issue completo y luego la guía de contribución del proyecto.
- Comenta en el issue que vas a ocuparte — evita que dos personas hagan lo mismo.
- Haz un fork del repositorio y trabaja en una rama.
- Abre un pull request que haga referencia al número del issue.
Más de dpkp/kafka-python
-
Transactional producer's sender loops on AttributeError after a fatal error (2.2 and 2.3 branches)Abierto
Dificultad 2/5 1-3 horas Aptitud para principiantes 78/100
dpkp/kafka-python#3161 ·
-
StickyPartitionAssignor.assign() loops forever when members subscribe to different topicsPosiblemente ocupada @mstojcevich la tomó hace 12 días. Abierto
Dificultad 4/5 3-5 días Aptitud para principiantes 15/100
dpkp/kafka-python#3163 ·
-
Dificultad 1/5 Menos de una hora Aptitud para principiantes 12/100
dpkp/kafka-python#3162 ·
-
Sender: KeyError from muted.remove() while expiring batches orphans the rest; flush() hangs foreverPosiblemente ocupada @zhechen-cs la tomó hace 10 días. Abierto
Dificultad 3/5 1-2 días Aptitud para principiantes 76/100
dpkp/kafka-python#3159 ·
-
Dificultad 4/5 3-5 días Aptitud para principiantes 35/100
dpkp/kafka-python#3122 · 13 comentarios ·
Todos los issues de dpkp/kafka-python
Issues similares
-
Uninstall guide omits the CloudWatch log groups AWS CodeBuild creates for useCodeBuild pipelinesAbiertobug documentation
Dificultad 1/5 1-3 horas Aptitud para principiantes 88/100
awslabs/visual-asset-management-system#552 ·
Los mantenedores suelen responder en 1 día
-
netbox status: needs triage type: documentation
Dificultad 1/5 Menos de una hora Aptitud para principiantes 76/100
netbox-community/netbox#23460 ·
Los mantenedores suelen responder en 1 día
-
Dificultad 2/5 1-3 horas Aptitud para principiantes 75/100
awslabs/threat-composer#362 ·
Los mantenedores suelen responder en 1 día
-
Dificultad 2/5 1-3 horas Aptitud para principiantes 78/100
Los mantenedores suelen responder en 1 día
-
bug
Dificultad 2/5 1-3 horas Aptitud para principiantes 72/100
ansys/pyansys-common-mcp#213 ·
Los mantenedores suelen responder en 3 días