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 Kafka se reinicia para descartar datos antiguos
Vista: 21274|Respuesta: 1

[Fuente] Spring Boot Kafka se reinicia para descartar datos antiguos

[Copiar enlace]
Publicado el 14-11-2021 21:42:26 | | |
Requisitos: Cuando se inicia la aplicación Spring Boot, se leerá parte de la información de configuración de la base de datos o caché, y Kafka se usará para suscribirse a los cambios de información de configuración. Como la app comienza con la información de configuración más reciente, los mensajes sobre actualizaciones históricas de Kafka no significarán nada, y si usas mensajes históricos, tendrás problemas.

Después de que la app Spring Boot se reinicie, surge una pregunta sobre cómo descartar datos antiguos sobre un temaNo se reciben mensajes de Kafka sobre la historia de ese tema¿Éste? De hecho, este problema puede resolverse estableciendo el offset inicial, lo que permite al suscriptor establecer el offset del tema en la última posición antes de suscribirse al mensaje.

Incluso si spring.kafka.consumer.auto-offset-reset está configurado como más reciente, el consumidor leerá el mensaje desde el bit de bandera donde se confirmó que recibió el mensaje por última vez, lo que hará que el consumidor lea un gran número de mensajes tras reiniciar si el productor envía un gran número de mensajes cuando la app está cerrada.

El consumidor busca un desplazamiento específico durante la inicialización, con el siguiente código:

(Fin)





Anterior:Spring Boot establece dinámicamente el Topic o GroupId de Kafka
Próximo:Linux analiza la salida de registro del servicio Systemd

Publicaciones relacionadas
 Propietario| Publicado el 15-11-2021 10:37:05 |
Spring Boot establece dinámicamente el Topic o GroupId de Kafka
https://www.itsvse.com/thread-10152-1-1.html

Bajo CentOS 7, Kafka suele colgar soluciones
https://www.itsvse.com/thread-10090-1-1.html

El valor auto.offset.reset de Kafka se explica en detalle
https://www.itsvse.com/thread-10017-1-1.html

El sistema Kafka Windows se colga tras funcionar un tiempo
https://www.itsvse.com/thread-9984-1-1.html

ERROR de Kafka en Windows: No se ha conseguido limpiar el registro de __consumer_offsets
https://www.itsvse.com/thread-9980-1-1.html

Kafka configura la monitorización remota de JMX
https://www.itsvse.com/thread-9968-1-1.html

Explicación detallada de los parámetros de configuración de Kafka
https://www.itsvse.com/thread-9965-1-1.html

Kafka ajusta manualmente el desplazamiento
https://www.itsvse.com/thread-9641-1-1.html

Operaciones de Kafka para colas de mensajes .NET/C# [con código fuente]
https://www.itsvse.com/thread-9619-1-1.html
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