Тази статия е огледална статия за машинен превод, моля, кликнете тук, за да преминете към оригиналната статия.

Architect_Programmer_Code Селскостопанска мрежа»Архитект › Програмен › Ява › Spring Boot Kafka рестартира, за да изхвърли стари данни
Изглед: 21274|Отговор: 1

[Източник] Spring Boot Kafka рестартира, за да изхвърли стари данни

[Копирай линк]
Публикувано на 2021-11-14 21:42:26 | | |
Изисквания: Когато се стартира приложението за spring boot, част от конфигурационната информация ще бъде прочетена от базата данни или кеша, а Kafka ще се използва за абониране на промени в конфигурационната информация. Тъй като приложението започва с най-новата информация за конфигурацията, съобщенията за исторически актуализации на конфигурацията на Kafka ще бъдат безсмислени, а ако използвате исторически съобщения, ще имате проблеми.

След като приложението Spring Boot се рестартира, възниква въпрос как да се изхвърлят стари данни по дадена темаПосланията на Кафка за историята на тази тема не се получаватТози? Всъщност този проблем може да бъде решен чрез задаване на началното отклонение, което позволява на абоната да зададе офсета на темата на последната позиция преди да се абонира за съобщението.

Дори ако spring.kafka.consumer.auto-offset-reset е настроен на най-късно, потребителят ще прочете съобщението от бита на флага, където последно е потвърдено, че е получил съобщението, което ще накара потребителя да прочете голям брой съобщения след рестартиране, ако производителят изпрати голям брой съобщения при затваряне на приложението.

Потребителят търси специфично отместване по време на инициализацията, с следния код:

(Край)





Предишен:Spring Boot динамично задава темата или GroupID на Kafka
Следващ:Linux разглежда лог изхода на услугата Systemd

Свързани публикации
 Хазяин| Публикувано на 2021-11-15 10:37:05 |
Spring Boot динамично задава темата или GroupID на Kafka
https://www.itsvse.com/thread-10152-1-1.html

При CentOS 7 Кафка често спира решенията
https://www.itsvse.com/thread-10090-1-1.html

Стойността auto.offset.reset на Kafka е обяснена подробно
https://www.itsvse.com/thread-10017-1-1.html

Системата Kafka Windows затваря след определен период на работа
https://www.itsvse.com/thread-9984-1-1.html

Windows Kafka ГРЕШКА Не успя да почисти лога за __consumer_offsets
https://www.itsvse.com/thread-9980-1-1.html

Kafka конфигурира дистанционното наблюдение на JMX
https://www.itsvse.com/thread-9968-1-1.html

Подробно обяснение на параметрите на конфигурацията на Кафка
https://www.itsvse.com/thread-9965-1-1.html

Kafka ръчно задава офсетния офсет
https://www.itsvse.com/thread-9641-1-1.html

Кафка операции за .NET/C# опашки за съобщения [с изходен код]
https://www.itsvse.com/thread-9619-1-1.html
Отричане:
Целият софтуер, програмни материали или статии, публикувани от Code Farmer Network, са само за учебни и изследователски цели; Горното съдържание не трябва да се използва за търговски или незаконни цели, в противен случай потребителите ще понесат всички последствия. Информацията на този сайт идва от интернет, а споровете за авторски права нямат нищо общо с този сайт. Трябва напълно да изтриете горното съдържание от компютъра си в рамките на 24 часа след изтеглянето. Ако ви харесва програмата, моля, подкрепете оригинален софтуер, купете регистрация и получете по-добри услуги. Ако има нарушение, моля, свържете се с нас по имейл.
Mail To:help@itsvse.com