Kafka classe de erro
Alguns dados podem ter sido perdidos porque não estão mais disponíveis no Kafka; ou os dados foram envelhecidos pelo Kafka ou o tópico pode ter sido excluído antes que todos os dados do tópico fossem processados. Se o senhor não quiser que a consulta de transmissão falhe nesses casos, defina a opção de origem failOnDataLoss como false. Motivo:
ADICIONOU_PARTITION_DOES_NOT_START_FROM_OFFSET_ZERO
Adicionada a partição <topicPartition> começar de <startOffset> em vez de 0.
NÃO FOI POSSÍVEL LER O INTERVALO DE DESLOCAMENTO
Não foi possível ler registros em offset [<startOffset>, <endOffset>) para partição de tópico <topicPartition>
com o grupo de consumidores <groupId>.
INITIAL_OFFSET_NOT_FOUND_FOR_PARTITIONS
Não é possível encontrar compensações iniciais para partições <partitions>. Eles podem ter sido excluídos.
PARTIÇÕES_EXCLUÍDAS
As partições <partitions> foram excluídas.
PARTIÇÕES_EXCLUÍDAS_E_GROUP_ID_CONFIG_PRESENT
As partições <partitions> foram excluídas.
Kafka opção 'Kafka.<groupIdConfig>' foi definido nesta consulta, é
não é recomendável definir essa opção. Não é seguro usar essa opção, pois vários concorrente
consultas ou fontes usando o mesmo ID de grupo interferirão umas nas 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' seja muito pequeno para que o Kafka
Os consumidores da consulta anterior são marcados como mortos pelo coordenador do grupo Kafka antes que o
A consulta reiniciada começa a ser executada.
PARTIÇÃO_OFFSET_ALTERADA
O offset da partição <topicPartition> foi alterado de <prevOffset> para <newOffset>.
começar
O deslocamento inicial para <topicPartition> era <offset>, mas o consumidor redefiniu para <fetchedOffset>.