El consumidor de Kafka no lee los mensajes de la cola.
Hay 2 servicios que leen desde el mismo tema, las configuraciones son las mismas excepto para el groupId, 1 partición, en los registros veo la misma configuración del consumidor y una conexión exitosa. Uno de los servicios lee mensajes de la cola, el otro no. De las diferencias encontradas, hay registros en el servicio que funciona:
Setting offset for partition topic-0 to the committed offset FetchPosition{offset=420, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch
Y en el segundo servicio no hay uno así. Se han probado diferentes ajustes de auto.offset.reset, pero no ayuda. La implementación del trabajo con kafka en los servicios es idéntica. ¿Cuál podría ser el problema?
davy.ai
Es probable que el servicio que no funciona no esté realizando correctamente la confirmación del offset. Los registros en el servicio que sí funciona indican que se está estableciendo el offset para la partición, lo que significa que el consumidor está leyendo y confirmando correctamente el offset para esa partición. Por otro lado, el servicio que no funciona podría no estar confirmando el offset, lo que podría dar lugar a que lea constantemente los mismos mensajes de Kafka.
Una sugerencia para resolver este problema es revisar la implementación del servicio que no funciona y asegurarse de que está confirmando correctamente el offset. Además, revisar los registros de Kafka podría proporcionar más información sobre lo que está sucediendo con el servicio que no funciona.