Running processor on exception: startConsumeFromSequence has to be a positive number

[AndryHTC]

After the update to the 0.2.3 it gives me this error
Running processor on exception: startConsumeFromSequence has to be a positive number

[yanivbh1]

Adding @bazen-teklehaymanot for the help.
Thank you @AndryHTC .

[tbazen]

Hi @AndryHTC , can you please provide more detail on how to reproduce the issue?

Thanks!

[AndryHTC]

Well... This is the code I had before updating:

private static async Task SetupAndStartConsumer(string stationName, string consumerName,
        Func<MemphisMessage, Task<string>> processMessage)
    {
        var consumerOptions = new MemphisConsumerOptions
        {
            StationName = stationName,
            ConsumerName = consumerName,
            ConsumerGroup = "",
            PullIntervalMs = 100
        };

        var consumer = await _memphisClient!.CreateConsumer(consumerOptions);
        consumer.MessageReceived += async (_, e) =>
        {
            if (e.Exception != null)
            {
                Console.Error.WriteLine(e.Exception);
                return;
            }
            
            var producerOptions = new MemphisProducerOptions
            {
                StationName = "pontis-meilisearch-events",
                ProducerName = "debezium-to-meilisearch-producer",
                GenerateUniqueSuffix = true
            };
            _producer = await _memphisClient.CreateProducer(producerOptions);
            var commonHeaders = new NameValueCollection { { "produced-by", "debezium-to-meilisearch-producer" } };

            var messageProcessingTasks = new Dictionary<Task<string>, MemphisMessage>();
            foreach (var msg in e.MessageList)
            {
                var task = processMessage(msg);
                messageProcessingTasks.Add(task, msg);
            }

            while (messageProcessingTasks.Count > 0)
            {
                var completedTask = await Task.WhenAny(messageProcessingTasks.Keys);
                var msg = messageProcessingTasks[completedTask];

                if (completedTask.Status == TaskStatus.RanToCompletion)
                {
                    await _producer.ProduceAsync(
                        Encoding.UTF8.GetBytes(completedTask.Result),
                        commonHeaders
                    );
                    msg.Ack();
                }
                else
                {
                    await Console.Error.WriteLineAsync($"Message processing failed: {completedTask.Exception}");
                    SentrySdk.CaptureException(completedTask.Exception!);
                }

                messageProcessingTasks.Remove(completedTask);
            }
        };

        consumer.ConsumeAsync();
    }

After the update to 0.2.3 it gives me that error so I rolled back to the 0.2.2. I don't have many other info

[tbazen]

Thanks @AndryHTC, I'm merging the fix it will be available on the next release

[AndryHTC]

Any idea on when will be published the next release?

[yanivbh1]

Hey @AndryHTC , Aug 7.