Эта статья является зеркальной статьёй машинного перевода, пожалуйста, нажмите здесь, чтобы перейти к оригиналу.

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 Кафки подробно объяснено
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

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