Questo articolo è un articolo speculare di traduzione automatica, clicca qui per saltare all'articolo originale.

Architect_Programmer_Code Rete Agricola»Architetto › Programmazione › Giava › Spring Boot Kafka riavvia per scartare i dati vecchi
Vista: 21274|Risposta: 1

[Fonte] Spring Boot Kafka riavvia per scartare i dati vecchi

[Copiato link]
Pubblicato il 14-11-2021 21:42:26 | | |
Requisiti: Quando l'applicazione spring boot viene avviata, alcune informazioni di configurazione verranno lette dal database o dalla cache, e Kafka verrà utilizzato per abbonarsi alle modifiche delle informazioni di configurazione. Poiché l'app parte con le ultime informazioni di configurazione, i messaggi sugli aggiornamenti storici di Kafka saranno privi di significato, e se usi messaggi storici avrai problemi.

Dopo il riavvio dell'app Spring Boot, surge una domanda su come scartare i dati vecchi su un argomentoI messaggi di Kafka sulla storia di quell'argomento non vengono ricevutiQuesto? In effetti, questo problema può essere risolto impostando lo offset iniziale, che permette all'abbonato di impostare l'offset dell'argomento all'ultima posizione prima di sottoscrivere il messaggio.

Anche se spring.kafka.consumer.auto-offset-reset è impostato su più tardo, il consumatore leggerà il messaggio dal bit di flag dove è stato confermato l'ultima ricezione, il che farà leggere un gran numero di messaggi dopo il riavvio se il produttore invia un gran numero di messaggi quando l'app è chiusa.

Il consumatore cerca un offset specifico durante l'inizializzazione, con il seguente codice:

(Fine)





Precedente:Spring Boot imposta dinamicamente il Topic o GroupId di Kafka
Prossimo:Linux esamina l'output log del servizio Systemd

Post correlati
 Padrone di casa| Pubblicato il 15-11-2021 alle 10:37:05 |
Spring Boot imposta dinamicamente il Topic o GroupId di Kafka
https://www.itsvse.com/thread-10152-1-1.html

Con CentOS 7, Kafka spesso blocca le soluzioni
https://www.itsvse.com/thread-10090-1-1.html

Il valore auto.offset.reset di Kafka è spiegato in dettaglio
https://www.itsvse.com/thread-10017-1-1.html

Il sistema Kafka Windows si blocca dopo essere stato avviato per un certo periodo
https://www.itsvse.com/thread-9984-1-1.html

ERRORE Kafka di Windows: Errore non riuscito a pulire il log per __consumer_offsets
https://www.itsvse.com/thread-9980-1-1.html

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

Spiegazione dettagliata dei parametri di configurazione di Kafka
https://www.itsvse.com/thread-9965-1-1.html

Kafka imposta manualmente l'offset
https://www.itsvse.com/thread-9641-1-1.html

Operazioni Kafka per code di messaggi .NET/C# [con codice sorgente]
https://www.itsvse.com/thread-9619-1-1.html
Disconoscimento:
Tutto il software, i materiali di programmazione o gli articoli pubblicati dalla Code Farmer Network sono destinati esclusivamente all'apprendimento e alla ricerca; I contenuti sopra elencati non devono essere utilizzati per scopi commerciali o illegali, altrimenti gli utenti dovranno sostenere tutte le conseguenze. Le informazioni su questo sito provengono da Internet, e le controversie sul copyright non hanno nulla a che fare con questo sito. Devi eliminare completamente i contenuti sopra elencati dal tuo computer entro 24 ore dal download. Se ti piace il programma, ti preghiamo di supportare software autentico, acquistare la registrazione e ottenere servizi autentici migliori. In caso di violazione, vi preghiamo di contattarci via email.
Mail To:help@itsvse.com