`kafka_event_aggregator`: backpressure
Nadie ha tomado este issue todavía.
Evaluación
- Dificultad
- 5/5
- Tiempo estimado
- Más de una semana
- Aptitud para principiantes
- 45/100
- Tipo de issue
- Nueva funcionalidad
- Claridad
- Bastante claro
- Estado de actividad
- Activo
- Stack tecnológico
- kafka
- Área
- stream-processing
Línea de trabajo
Comienza en el punto de entrada kafka_event_aggregator y rastrea cómo se gestionan el tamaño de la cola del producer, las lecturas del consumer y los límites de los frames. Define los umbrales N/M y confirma cómo debería funcionar la pausa a mitad de un frame; el trabajo estará terminado cuando la pausa y la recuperación del consumer, las advertencias y las métricas de pausa estén implementadas sin perder ni gestionar incorrectamente frames parciales.
Escrito por el modelo de indexación a partir del texto del issue.
Descripción
If producer queue fills beyond N bytes, pause consumer until it recovers to less than M bytes (and provide warnings + metrics about consumer pause).
(need to consider behaviour on pausing consumer mid-frame - we are likely to get partial frames in that case)
- Lenguaje dominante
- Sin datos de lenguaje
- Estrellas
- 0
- Forks
- 0
- Métricas de merge de PR
- Sin PR fusionados en 30 d
Guía de contribución
No hay ninguna guía de contribución indexada para este repositorio
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 ISISComputingGroup/DataStreaming
-
ISISComputingGroup/DataStreaming#115 · 1 asignado ·
-
Filewriter: implement structure Abierto
ISISComputingGroup/DataStreaming#114 · 1 asignado ·
-
Dificultad 4/5 3-5 días Aptitud para principiantes 35/100
-
Dificultad 3/5 1-2 días Aptitud para principiantes 48/100
-
`kafka_dae_control`: unset pause on runstart, or set it if doing an explicit `begin(paused=True)` Abierto
ISISComputingGroup/DataStreaming#109 · 1 comentario · 1 asignado ·
Todos los issues de ISISComputingGroup/DataStreaming
Issues similares
-
Dificultad 2/5 1-3 horas Aptitud para principiantes 78/100
-
Dificultad 2/5 1-3 horas Aptitud para principiantes 86/100
membraneframework/boombox#149 · 1 asignado ·
-
automation flaky-test Integration:kafka_input_otel Team:obs-ds-intake-services
Dificultad 2/5 1-3 horas Aptitud para principiantes 70/100
elastic/integrations#21346 ·
-
priority: P2
Dificultad 2/5 1-3 horas Aptitud para principiantes 72/100
-
Dificultad 2/5 1-3 horas Aptitud para principiantes 82/100
vectordotdev/vector#26389 ·