Este artículo es un artículo espejo de traducción automática, por favor haga clic aquí para saltar al artículo original.

Architect_Programmer_Code Red Agrícola»Arquitecto › Programación › Java › Spring Boot establece dinámicamente el Topic o GroupId de Kafka
Vista: 21474|Respuesta: 0

[Fuente] Spring Boot establece dinámicamente el Topic o GroupId de Kafka

[Copiar enlace]
Publicado en 14/11/2021 20:03:45 | | | |
Al desplegar microservicios en un clúster, si queremos emitir comandos a todas las aplicaciones, podemos suscribir las aplicaciones a temas de Kafka, pero debe señalarse que es necesario establecer diferentes groupIDs para que el mismo tema sea recibido por todas las aplicaciones.

Utiliza docker para construir una aplicación Kafka con los siguientes comandos:

Nota: Sustituye 192.168.1.166 por tu dirección IP real

pom.xml Introduce el paquete resorte-kafka de la siguiente manera:


Para personalizar la configuración de Kafka Consumer, crea un nuevo archivo KafkaConsumer de la siguiente manera:


Crea un nuevo ConfigurConsumidor para consumidores, que tenga la configuración predeterminada: topic:defaultTopic,groupid:defaultGroupId, y el código es el siguiente:

application.properties para configurar la dirección de Kafka:


Para iniciar un proyecto, la suscripción a la app es la configuración predeterminada, de la siguiente manera:



KafkaMessageListenerContainer hereda la clase abstracta AbstractMessageListenerContainer, y el método createSimpleLoggingConsumerRebalanceListener genera la partición groupid y topic del consumidor.

2021-11-14 19:44:26.689 INFO 14256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : defaultGroupId: particiones asignadas: [defaultTopic-0]
Establece dinámicamente el topic y groupid, y el comando de inicio del proyecto es el siguiente:



El tema está configurado en a1 y el groupid es itsvse.com

2021-11-14 19:46:25.330 INFO 12256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : itsvse.com: particiones asignadas: [a1-0]
El muelle anula la configuración predeterminada dentro del paquete jar
https://www.itsvse.com/thread-10129-1-1.html

(Fin)





Anterior:Consultas lentas para optimización del rendimiento en MySQL
Próximo:Spring Boot Kafka se reinicia para descartar datos antiguos

Publicaciones relacionadas
Renuncia:
Todo el software, materiales de programación o artículos publicados por Code Farmer Network son únicamente para fines de aprendizaje e investigación; El contenido anterior no se utilizará con fines comerciales o ilegales; de lo contrario, los usuarios asumirán todas las consecuencias. La información de este sitio proviene de Internet, y las disputas de derechos de autor no tienen nada que ver con este sitio. Debes eliminar completamente el contenido anterior de tu ordenador en un plazo de 24 horas desde la descarga. Si te gusta el programa, por favor apoya el software genuino, compra el registro y obtén mejores servicios genuinos. Si hay alguna infracción, por favor contáctanos por correo electrónico.
Mail To:help@itsvse.com