KAFKA_DATA_LOSS classe de erro
Alguns dados podem ter sido perdidos porque já não estão disponíveis em Kafka; ou os dados foram envelhecidos por Kafka ou o tópico pode ter sido excluído antes que todos os dados no tópico fossem processados. Se você não quiser que sua 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 a partir de <startOffset> em vez de 0.
COULD_NOT_READ_OFFSET_RANGE
Não foi possível ler registros no deslocamento [<startOffset>, <endOffset>) para partição de tópico <topicPartition>
com grupo <groupId>de consumidores .
INITIAL_OFFSET_NOT_FOUND_FOR_PARTITIONS
Não é possível encontrar deslocamentos <partitions>iniciais para partições . Podem ter sido suprimidos.
PARTITIONS_DELETED
As partições foram excluídas <partitions> .
PARTITIONS_DELETED_AND_GROUP_ID_CONFIG_PRESENT
As partições foram excluídas <partitions> .
Kafka opção 'kafka'.<groupIdConfig> foi definido nesta consulta, é
não recomendado para definir esta opção. Esta opção não é segura de usar, uma vez que várias
Consultas ou fontes que usam o mesmo ID de grupo interferirão umas com as outras, pois fazem parte
do mesmo grupo de consumidores. As consultas reiniciadas também podem sofrer interferência do
Execução anterior com o mesmo 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' para ser muito pequena para que o Kafka
os consumidores da consulta anterior são marcados como mortos pelo coordenador do grupo Kafka antes do
A consulta reiniciada começa a ser executada.
PARTITION_OFFSET_CHANGED
O deslocamento de partição <topicPartition> foi alterado de <prevOffset> para <newOffset>.
START_OFFSET_RESET
Compensação inicial para <topicPartition> foi <offset> mas consumidor redefinir para <fetchedOffset>.