Ця стаття є дзеркальною статтею машинного перекладу, будь ласка, натисніть тут, щоб перейти до оригінальної статті.

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

Кафка вручну встановлює зміщення зсуву
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