Prasības: Kad tiek palaista pavasara sāknēšanas lietojumprogramma, daļa konfigurācijas informācijas tiks nolasīta no datu bāzes vai kešatmiņas, un Kafka tiks izmantota, lai abonētu konfigurācijas informācijas izmaiņas. Tā kā lietotne tiek startēta ar jaunāko konfigurācijas informāciju, ziņojumi par vēsturiskajiem Kafka konfigurācijas atjauninājumiem būs bezjēdzīgi, un, ja izmantojat vēsturiskos ziņojumus, jums radīsies problēmas.
Pēc Spring Boot lietotnes restartēšanas rodas jautājums par to, kā atmest vecos datus par tēmuKafkas ziņojumi par šīs tēmas vēsturi netiek saņemtiŠis? Faktiski šo problēmu var atrisināt, iestatot sākuma nobīdi, kas ļauj abonentam iestatīt tēmas nobīdi uz pēdējo pozīciju pirms ziņojuma abonēšanas.
Pat ja spring.kafka.consumer.auto-offset-reset ir iestatīts uz jaunāko, patērētājs nolasīs ziņojumu no karodziņa bita, kurā pēdējo reizi tika apstiprināts, ka ir saņēmis ziņojumu, kā rezultātā patērētājs pēc restartēšanas lasīs lielu skaitu ziņojumu, ja ražotājs nosūta lielu skaitu ziņojumu, kad lietotne ir aizvērta.
Patērētājs inicializācijas laikā meklē konkrētu nobīdi ar šādu kodu:
(Beigas)
|
Publicēts 2021-11-14 21:42:26
|
|
|
Saimnieks|
Publicēts 2021-11-15 10:37:05
|
