Classe de erro KAFKA_DATA_LOSS
Alguns dados podem ter sido perdidos porque não estão mais disponíveis no Kafka; os dados foram apagados pelo Kafka ou o tópico pode ter sido excluído antes de todos os dados no tópico serem processados. Se você não quiser que a consulta de streaming falhe nesses casos, defina a opção de origem failOnDataLoss como false. Motivo:
ADDED_PARTITION_DOES_NOT_START_FROM_OFFSET_ZERO
A partição <topicPartition> adicionada começa em <startOffset> em vez de 0.
COULD_NOT_READ_OFFSET_RANGE
Não foi possível ler registros em deslocamento [<startOffset>, <endOffset>) para a partição de tópico <topicPartition>
com o grupo de consumidores <groupId>.
INITIAL_OFFSET_NOT_FOUND_FOR_PARTITIONS
Não é possível localizar deslocamentos iniciais para partições <partitions>. Talvez eles já tenham sido excluídos.
PARTITIONS_DELETED
As partições <partitions> foram excluídas.
PARTITIONS_DELETED_AND_GROUP_ID_CONFIG_PRESENT
As partições <partitions> foram excluídas.
A opção 'kafka.<groupIdConfig>' do Kafka foi definida nesta consulta, não
é recomendado definir essa opção. Essa opção não é segura de usar, pois várias consultas
ou origens simultâneas que usem a mesma ID de grupo interferirão uma com a outra, pois fazem parte
do mesmo grupo de consumidores. As consultas reiniciadas também podem sofrer interferência da
execução anterior, tendo a mesma ID de grupo. O usuário deve ter apenas uma consulta por ID de grupo,
e/ou definir a opção 'kafka.session.timeout.ms' como muito pequena, para que os
consumidores do Kafka da consulta anterior sejam marcados como inativos pelo coordenador do grupo Kafka antes que a
consulta reiniciada comece a ser executada.
PARTITION_OFFSET_CHANGED
O deslocamento de partição <topicPartition> foi alterado de <prevOffset> para <newOffset>.
START_OFFSET_RESET
O deslocamento inicial para <topicPartition> era <offset>, mas o consumidor redefiniu-o para <fetchedOffset>.