Este artigo é um artigo espelhado de tradução automática, por favor clique aqui para ir para o artigo original.

Architect_Programmer_Code Rede Agrícola»Arquiteto › Programação › Java › O Spring Boot Kafka reinicia para descartar dados antigos
Vista: 21274|Resposta: 1

[Fonte] O Spring Boot Kafka reinicia para descartar dados antigos

[Copiar link]
Postado em 2021-11-14 21:42:26 | | |
Requisitos: Quando o aplicativo spring boot é iniciado, algumas informações de configuração serão lidas do banco de dados ou cache, e o Kafka será usado para assinar as mudanças nas informações de configuração. Como o app começa com as informações de configuração mais recentes, mensagens sobre atualizações históricas de configuração do Kafka não terão significado, e se você usar mensagens históricas, terá problemas.

Depois que o app Spring Boot reinicia, surge uma dúvida sobre como descartar dados antigos sobre um temaMensagens de Kafka sobre a história desse tema não são recebidasEste? Na verdade, esse problema pode ser resolvido definindo o offset inicial, que permite ao assinante definir o offset do tópico para a última posição antes de assinar a mensagem.

Mesmo que spring.kafka.consumer.auto-offset-reset esteja configurado como mais tarde, o consumidor lerá a mensagem do bit de flag onde foi confirmado pela última vez que recebeu a mensagem, o que fará com que o consumidor leia um grande número de mensagens após reiniciar se o produtor enviar um grande número de mensagens quando o app estiver fechado.

O consumidor busca um deslocamento específico durante a inicialização, com o seguinte código:

(Fim)





Anterior:O Spring Boot define dinamicamente o Topic ou GroupId de Kafka
Próximo:O Linux analisa a saída de logs do serviço Systemd

Posts Relacionados
 Senhorio| Postado em 2021-11-15 10:37:05 |
O Spring Boot define dinamicamente o Topic ou GroupId de Kafka
https://www.itsvse.com/thread-10152-1-1.html

No CentOS 7, Kafka frequentemente desliga soluções
https://www.itsvse.com/thread-10090-1-1.html

O valor auto.offset.reset do Kafka é explicado em detalhes
https://www.itsvse.com/thread-10017-1-1.html

O sistema Kafka Windows trava após rodar por um período de tempo
https://www.itsvse.com/thread-9984-1-1.html

ERRO do Windows Kafka Falhou em limpar o log para __consumer_offsets
https://www.itsvse.com/thread-9980-1-1.html

Kafka configura monitoramento remoto JMX
https://www.itsvse.com/thread-9968-1-1.html

Explicação detalhada dos parâmetros de configuração de Kafka
https://www.itsvse.com/thread-9965-1-1.html

Kafka define manualmente o deslocamento
https://www.itsvse.com/thread-9641-1-1.html

Operações Kafka para filas de mensagens .NET/C# [com código-fonte]
https://www.itsvse.com/thread-9619-1-1.html
Disclaimer:
Todo software, material de programação ou artigos publicados pela Code Farmer Network são apenas para fins de aprendizado e pesquisa; O conteúdo acima não deve ser usado para fins comerciais ou ilegais, caso contrário, os usuários terão todas as consequências. As informações deste site vêm da Internet, e disputas de direitos autorais não têm nada a ver com este site. Você deve deletar completamente o conteúdo acima do seu computador em até 24 horas após o download. Se você gosta do programa, por favor, apoie um software genuíno, compre o registro e obtenha serviços genuínos melhores. Se houver qualquer infração, por favor, entre em contato conosco por e-mail.
Mail To:help@itsvse.com