Este código define duas funções: automatizado e manual.
A função automatizada processa registos de um tópico Kafka e insere-os numa tabela de base de dados. A função devolve o primeiro ID de processo inserido. Se não houver novos registos, a função verifica se há registos previamente enviados que falharam, e se assim for, devolve o primeiro ID de processo falhado. Se não houver registos falhados, a função atira um erro indicando não haver novos registos disponíveis. A função manual devolve a ID do primeiro processo na tabela da base de dados com um estado de “Novo”.