KAFKA_DATA_LOSS clase de error
Es posible que algunos datos se hayan perdido porque ya no están disponibles en Kafka; ya sea que Kafka ha antiguo los datos o que el tema se haya eliminado antes de que se procesen todos los datos del tema. Si no desea que la consulta de streaming produzca un error en estos casos, establezca la opción de origen failOnDataLoss en false. Motivo:
ADDED_PARTITION_DOES_NOT_START_FROM_OFFSET_ZERO
Se ha agregado <topicPartition> partición a partir de <startOffset> en lugar de 0.
COULD_NOT_READ_OFFSET_RANGE
No se pudieron leer registros en desplazamiento [<startOffset>, <endOffset>) para la partición del tema <topicPartition>
con el grupo de consumidores <groupId>.
INITIAL_OFFSET_NOT_FOUND_FOR_PARTITIONS
No se pueden encontrar desplazamientos iniciales para las particiones <partitions>. Es posible que se hayan eliminado.
PARTITIONS_DELETED
Se han eliminado las particiones <partitions>.
PARTITIONS_DELETED_AND_GROUP_ID_CONFIG_PRESENT
Se han eliminado las particiones <partitions>.
Kafka opción ‘kafka.<groupIdConfig>’ se ha establecido en esta consulta, es
no se recomienda establecer esta opción. Esta opción no es segura de usar, ya que hay varias simultáneas
las consultas o orígenes que usan el mismo identificador de grupo interferirán entre sí, ya que forman parte
del mismo grupo de consumidores. Las consultas reiniciadas también pueden sufrir interferencias de
ejecución anterior que tiene el mismo identificador de grupo. El usuario debe tener solo una consulta por identificador de grupo,
o establezca la opción ‘kafka.session.timeout.ms’ ser muy pequeña para que kafka
los consumidores de la consulta anterior se marcan como inactivos por el coordinador del grupo de Kafka antes de
la consulta reiniciada comienza a ejecutarse.
PARTITION_OFFSET_CHANGED
El desplazamiento de <topicPartition> partición se cambió de <prevOffset> a <newOffset>.
START_OFFSET_RESET
El desplazamiento inicial de <topicPartition> se <offset>, pero el restablecimiento del consumidor se restablece a <fetchedOffset>.