Как обрабатывать сообщение фиксации Kafka, когда данные не сохраняются в базе данных ⇐ C#

[Anonymous]

Мы с Net Core получаем сообщения от Kafka. У меня есть реализация ниже

Код: Выделить всё

  while(true)
{
var consumeResult = consumer.Consume(TimeSpan.FromSeconds(20));

if(consumeResult?.Message is not null)
{
// do processing
// add data to list(some sample list every time I am adding data to list)
// commit the message received
}
}

Теперь вне цикла while я передаю список (полученные данные) в свою базу данных.
теперь моя проблема в том, что я прочитаю все свои сообщения и добавлен в список, но в базе данных произошло какое-то исключение, и все данные не сохраняются в базе данных, но я уже зафиксировал сообщение внутри цикла while, поэтому, если программа выполнится снова, я не получу данные снова, потому что они уже зафиксированы. Итак, может ли кто-нибудь помочь мне справиться с этой ситуацией? Любая помощь в его отношении приветствуется. Спасибо

Подробнее здесь: https://stackoverflow.com/questions/785 ... -data-base