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

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

[Източник] Spring Boot динамично задава темата или GroupID на Kafka

[Копирай линк]
Публикувано в 14.11.2021 г. 20:03:45 ч. | | | |
При внедряване на микросервиси в клъстер, ако искаме да издаваме команди на всички приложения, можем да абонираме приложенията към Kafka теми, но трябва да се отбележи, че трябва да се зададат различни groupID-та, за да могат всички приложения да приемат една и съща тема.

Използвайте 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 INFO 14256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : defaultGroupId: разпределени дялове: [defaultTopic-0]
Динамично задайте темата и groupid и командата 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]
Пружината замества стандартната конфигурация вътре в jar пакета
https://www.itsvse.com/thread-10129-1-1.html

(Край)





Предишен:Бавни заявки за оптимизация на производителността на MySQL
Следващ:Spring Boot Kafka рестартира, за да изхвърли стари данни

Свързани публикации
Отричане:
Целият софтуер, програмни материали или статии, публикувани от Code Farmer Network, са само за учебни и изследователски цели; Горното съдържание не трябва да се използва за търговски или незаконни цели, в противен случай потребителите ще понесат всички последствия. Информацията на този сайт идва от интернет, а споровете за авторски права нямат нищо общо с този сайт. Трябва напълно да изтриете горното съдържание от компютъра си в рамките на 24 часа след изтеглянето. Ако ви харесва програмата, моля, подкрепете оригинален софтуер, купете регистрация и получете по-добри услуги. Ако има нарушение, моля, свържете се с нас по имейл.
Mail To:help@itsvse.com