Twisted interface
@dpkp ya está trabajando en esto.
Desde el 16/7/2016.
Evaluación
Este issue todavía no se ha evaluado.
Descripción
Kafka-Python claims to be "async" but this seems to just mean "uses lots of threads to put your I/O into the background" and not actually "event-driven". It would be nice to have an interface which avoids the overhead (thread stacks, GIL switching, etc) and risks (sharing too much state, deadlocks, difficult to debug differing behavior at scale) of threads, but presents a similar interface.
I filed the ticket with the summary "twisted" because of my particular biases, but this should be done in a way which is as framework-neutral as possible, since supporting the asyncio stdlib module at some point in the future would probably be interesting as well, not to mention Tornado and Vanilla and so on.
Given that one would be consuming a queue, perhaps this would be a good landmark project for https://github.com/twisted/tubes which, despite its github URL, has an (almost) framework-neutral architecture and lots of good abstractions around flow control and propagating backpressure.
- 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 10 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 8 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
-
bug
Dificultad 2/5 1-3 horas Aptitud para principiantes 79/100
Los mantenedores suelen responder en 1 día
-
Dificultad 2/5 1-3 horas Aptitud para principiantes 78/100
mohitmishra786/readprism#322 ·
Los mantenedores suelen responder en 1 día
-
good first issue
Dificultad 2/5 1-3 horas Aptitud para principiantes 76/100
-
Dificultad 1/5 Menos de una hora Aptitud para principiantes 75/100
Los mantenedores suelen responder en 1 día
-
API-key credentials accept a blank key: empty via the API, spaces-only via the builder's Add API key dialogPosiblemente ocupada Un pull request vinculado a esta issue está abierto o ya se fusionó. Abierto
Dificultad 2/5 1-3 horas Aptitud para principiantes 77/100
Significant-Gravitas/AutoGPT#15727 ·
Los mantenedores suelen responder en 1 día