search

Arquisoft / InciDashboard_e3b

InciDashboard_e3b
The Unlicense
0 stars 1 forks source link

BUG: InciDashboard no recibe los mensajes de InciManager a través de Apache Kafka #26

Closed kilianpg closed 6 years ago

kilianpg commented 6 years ago

Una vez iniciado el servicio InciDashboard ignora los mensajes enviados a través de Apache Kafka desde InciManager:

[...]

[INFO] DOCKER> [arquisoft.ddns.net/incidashboard_e3b:latest] "incidashboard_e3b": Waited on url http://localhost:8092 52008 ms
incidashboard_e3b [a59143711344] |2018-05-26 16:00:31.887  INFO 1 --- [afka-consumer-1] o.a.k.c.c.internals.AbstractCoordinator  : Attempt to heart beat failed since the group is rebalancing, try to re-join group.
incidashboard_e3b [a59143711344] |2018-05-26 16:00:31.887  INFO 1 --- [afka-consumer-1] o.s.k.l.KafkaMessageListenerContainer    : partitions revoked:[]
kafka [29dcd26e9c42] |[2018-05-26 16:00:31,895] INFO [GroupCoordinator 1001]: Stabilized group es.uniovi generation 2 (__consumer_offsets-10) (kafka.coordinator.group.GroupCoordinator)
kafka [29dcd26e9c42] |[2018-05-26 16:00:31,909] INFO [GroupCoordinator 1001]: Assignment received from leader for group es.uniovi for generation 2 (kafka.coordinator.group.GroupCoordinator)
incidashboard_e3b [a59143711344] |2018-05-26 16:00:31.937  INFO 1 --- [afka-consumer-1] o.s.k.l.KafkaMessageListenerContainer    : partitions assigned:[]
incidashboard_e3b [a59143711344] |2018-05-26 16:00:31.941  INFO 1 --- [afka-consumer-1] o.s.k.l.KafkaMessageListenerContainer    : partitions assigned:[]
incidashboard_e3b [a59143711344] |2018-05-26 16:00:31.941  INFO 1 --- [afka-consumer-1] o.s.k.l.KafkaMessageListenerContainer    : partitions assigned:[]

incimanager_e3b [443bb23e239f] |2018-05-26 16:00:57.168  INFO 1 --- [nio-8091-exec-5] e.u.a.e.i.i.services.IncidenceService    : Sending incidence "Incidencia de prueba" to topic 'incidences'
kafka [29dcd26e9c42] |[2018-05-26 16:00:57,429] INFO Updated PartitionLeaderEpoch. New: {epoch:0, offset:0}, Current: {epoch:-1, offset:-1} for Partition: incidences-0. Cache now contains 0 entries. (kafka.server.epoch.LeaderEpochFileCache)
incimanager_e3b [443bb23e239f] |2018-05-26 16:00:57.506  INFO 1 --- [ad | producer-4] e.u.a.e.i.kafka.producers.KafkaProducer  : Success on sending message "{"username":"paco@gmail.com","password":"123456","incidenceName":"Incidencia de prueba","description":"Descripción de la incidencia de prueba","location":"43.3582617,-5.8531647","labels":["prueba","sensor"],"status":"ABIERTA","expiration":"Mar 24, 2018 11:00:00 PM","cacheable":true}" to topic incidences

incimanager_e3b [443bb23e239f] |2018-05-26 16:02:14.260  INFO 1 --- [nio-8091-exec-7] e.u.a.e.i.i.services.IncidenceService    : Sending incidence "Incidencia de prueba" to topic 'incidences'
incimanager_e3b [443bb23e239f] |2018-05-26 16:02:14.268  INFO 1 --- [ad | producer-4] e.u.a.e.i.kafka.producers.KafkaProducer  : Success on sending message "{"username":"paco@gmail.com","password":"123456","incidenceName":"Incidencia de prueba","description":"Descripción de la incidencia de prueba","location":"43.3582617,-5.8531647","labels":["prueba","sensor"],"status":"ABIERTA","expiration":"Mar 24, 2018 11:00:00 PM","cacheable":true}" to topic incidences

[...]

Pasado un tiempo (~180 segundos) se revoca automáticamente las particiones de Kafka asignandose la partición correspondiente al topic "incidences" y aparir de entonces empieza a funcionar (hasta que se reinicia de nuevo todo el servicio):

[...]

incidashboard_e3b [a59143711344] |2018-05-26 16:05:28.652  INFO 1 --- [afka-consumer-1] o.s.k.l.KafkaMessageListenerContainer    : partitions revoked:[]
kafka [29dcd26e9c42] |[2018-05-26 16:05:28,653] INFO [GroupCoordinator 1001]: Preparing to rebalance group es.uniovi with old generation 2 (__consumer_offsets-10) (kafka.coordinator.group.GroupCoordinator)
incidashboard_e3b [a59143711344] |2018-05-26 16:05:29.009  INFO 1 --- [afka-consumer-1] o.s.k.l.KafkaMessageListenerContainer    : partitions revoked:[]
incidashboard_e3b [a59143711344] |2018-05-26 16:05:29.017  INFO 1 --- [afka-consumer-1] o.s.k.l.KafkaMessageListenerContainer    : partitions revoked:[]
kafka [29dcd26e9c42] |[2018-05-26 16:05:29,019] INFO [GroupCoordinator 1001]: Stabilized group es.uniovi generation 3 (__consumer_offsets-10) (kafka.coordinator.group.GroupCoordinator)
kafka [29dcd26e9c42] |[2018-05-26 16:05:29,022] INFO [GroupCoordinator 1001]: Assignment received from leader for group es.uniovi for generation 3 (kafka.coordinator.group.GroupCoordinator)
incidashboard_e3b [a59143711344] |2018-05-26 16:05:29.026  INFO 1 --- [afka-consumer-1] o.s.k.l.KafkaMessageListenerContainer    : partitions assigned:[]
incidashboard_e3b [a59143711344] |2018-05-26 16:05:29.026  INFO 1 --- [afka-consumer-1] o.s.k.l.KafkaMessageListenerContainer    : partitions assigned:[]
incidashboard_e3b [a59143711344] |2018-05-26 16:05:29.032  INFO 1 --- [afka-consumer-1] o.s.k.l.KafkaMessageListenerContainer    : partitions assigned:[incidences-0]
incimanager_e3b [443bb23e239f] |2018-05-26 16:06:08.548  INFO 1 --- [nio-8091-exec-9] e.u.a.e.i.i.services.IncidenceService    : Sending incidence "Incidencia de prueba" to topic 'incidences'
incimanager_e3b [443bb23e239f] |2018-05-26 16:06:08.644  INFO 1 --- [ad | producer-4] e.u.a.e.i.kafka.producers.KafkaProducer  : Success on sending message "{"username":"paco@gmail.com","password":"123456","incidenceName":"Incidencia de prueba","description":"Descripción de la incidencia de prueba","location":"43.3582617,-5.8531647","labels":["prueba","sensor"],"status":"ABIERTA","expiration":"Mar 24, 2018 11:00:00 PM","cacheable":true}" to topic incidences
incidashboard_e3b [a59143711344] |2018-05-26 16:06:08.666  INFO 1 --- [afka-listener-1] e.u.a.e.i.listeners.IncidenceListener    : New incidence received: "{"username":"paco@gmail.com","password":"123456","incidenceName":"Incidencia de prueba","description":"Descripción de la incidencia de prueba","location":"43.3582617,-5.8531647","labels":["prueba","sensor"],"status":"ABIERTA","expiration":"Mar 24, 2018 11:00:00 PM","cacheable":true}" on topic 'incidences'

[...]
miguelms95 commented 6 years ago

En ejecución manual funciona correctamente, sin demoras.