Hacktoberfest 2026: as issues que os mantenedores marcaram para outubro, abertas e boas para iniciantes. Ver issues do Hacktoberfest

`kafka_event_aggregator`: backpressure

Aberta
#111 0 comentários 0 reações 0 responsáveis Ver no GitHub

Ninguém assumiu esta issue ainda.

Avaliação

Dificuldade
5/5
Tempo estimado
Mais de uma semana
Facilidade para iniciantes
45/100
Tipo de issue
Funcionalidade
Clareza
Razoavelmente clara
Status de atividade
Ativa
Stack de tecnologia
kafka
Domínio
stream-processing

Direção de pesquisa

Comece pelo ponto de entrada kafka_event_aggregator e rastreie como o tamanho da fila do producer, as leituras do consumer e os limites dos frames são tratados. Defina os limites N/M e confirme como a pausa no meio de um frame deve funcionar; o trabalho estará concluído quando a pausa e a recuperação do consumer, os avisos e as métricas de pausa estiverem implementados sem perder ou tratar incorretamente frames parciais.

Escrita pelo modelo de indexação a partir do texto da issue.

Descrição

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)

Linguagem predominante
Sem dados de linguagem
Estrelas
0
Forks
0
Nenhum PR com merge em 30d

Guia de contribuição

Nenhum guia de contribuição indexado para este repositório

Primeiros passos

  1. Leia a issue inteira e depois o guia de contribuição do projeto.
  2. Comente na issue dizendo que vai assumir — evita que duas pessoas façam o mesmo trabalho.
  3. Faça um fork do repositório e trabalhe em uma branch.
  4. Abra um pull request que referencie o número da issue.

Mais de ISISComputingGroup/DataStreaming

Todas as issues de ISISComputingGroup/DataStreaming

Issues semelhantes

Mais issues de Stream Processing

Receba novas issues na sua caixa de entrada

Um resumo curto de issues do GitHub para quem está começando.