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

Architect_Programmer_Code Сільськогосподарська мережа»Архітектор › Програмування › Ява › Spring Boot динамічно встановлює тему або GroupID Kafka
Вид: 21474|Відповідь: 0

[Джерело] Spring Boot динамічно встановлює тему або GroupID Kafka

[Копіювати посилання]
Опубліковано 14.11.2021 20:03:45 | | | |
При розгортанні мікросервісів у кластері, якщо ми хочемо видавати команди всім додаткам, ми можемо підписати їх на теми Kafka, але слід зазначити, що для отримання однієї й тієї ж теми всіма додатками потрібно встановлювати різні групові ID.

Використовуйте docker для створення додатку Kafka з такими командами:

Примітка: замініть 192.168.1.166 на вашу фактичну IP-адресу

pom.xml Представити пакет весняної кафки наступним чином:


Щоб налаштувати конфігурацію споживача Kafka, створіть новий файл KafkaConsumer наступним чином:


Створіть новий споживацький ConfigConsumer, який має конфігурацію за замовчуванням: topic:defaultTopic,groupid:defaultGroupId, і код виглядає так:

application.properties для налаштування адреси Kafka:


Для початку проєкту за замовчуванням є підписка на додаток за замовчуванням, наступним чином:



KafkaMessageListenerContainer успадковує абстрактний клас AbstractMessageListenerContainer, а метод createSimpleLoggingConsumerRebalanceListener виводить groupid споживача та розділ теми.

2021-11-14 19:44:26.689 ІНФО 14256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : defaultGroupId: розділи призначені: [defaultTopic-0]
Динамічно встановіть тему та групід, і команда start проєкту виглядає так:



Тема встановлена на a1, а групід — itsvse.com

2021-11-14 19:46:25.330 ІНФО 12256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : itsvse.com: розділи призначені: [a1-0]
Spring перекриває стандартну конфігурацію всередині jar-пакету
https://www.itsvse.com/thread-10129-1-1.html

(Кінець)





Попередній:Повільні запити для оптимізації продуктивності MySQL
Наступний:Spring Boot Kafka перезапускається для видалення старих даних

Пов'язані дописи
Застереження:
Усе програмне забезпечення, програмні матеріали або статті, опубліковані Code Farmer Network, призначені лише для навчання та досліджень; Вищезазначений контент не повинен використовуватися в комерційних чи незаконних цілях, інакше користувачі несуть усі наслідки. Інформація на цьому сайті надходить з Інтернету, і спори щодо авторських прав не мають до цього сайту. Ви повинні повністю видалити вищезазначений контент зі свого комп'ютера протягом 24 годин після завантаження. Якщо вам подобається програма, будь ласка, підтримуйте справжнє програмне забезпечення, купуйте реєстрацію та отримайте кращі справжні послуги. Якщо є будь-яке порушення, будь ласка, зв'яжіться з нами електронною поштою.
Mail To:help@itsvse.com