Long-running Process

[jlcarpenter]

I have a long running process and Kafka is timing out assuming that the consumer is no longer there and the message is placed back on the topic. I need a way to process my long running message but also continue to acknowledge that the consumer is still there so it does not give up on the message and reassign it.

Has anyone ever done this using KafkaFlow?

[jlcarpenter]

Below is the variation of code I have tried with no success.
`
var consumer = _consumerAccessor[context.ConsumerContext.ConsumerName];
var partitionId = context.ConsumerContext.Partition;
var partition = new Partition(partitionId);
var topicPartition = new TopicPartition(context.ConsumerContext.Topic, partition);
var topicPartitionList = new List()
{
topicPartition
};

    consumer.Pause(topicPartitionList);
    var pausedPartitions = consumer.PausedPartitions;

    var processTask =  Task.Run(() => _processFileService.ProcessFile(fileReceivedMsg));

    while (!processTask.IsCompleted)
    {
        consumer.Resume(topicPartitionList);
        _logger.LogInformation("{FileName} still processing, sleeping for 60 seconds", fileReceivedMsg.FileName);
        Thread.Sleep(60000);
        consumer.Pause(topicPartitionList);
    }
    consumer.Resume(topicPartitionList);

`