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

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 INFO 14256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : defaultGroupId: распределения назначены: [defaultTopic-0]
Динамически задавая тему и groupid, команда project start выглядит следующим образом:



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

2021-11-14 19:46:25.330 INFO 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