Я хочу снова использовать те же сообщения при перезапуске приложения с помощью Apache Kafka, но это занимает почти 1 мин ⇐ C#

[Anonymous]

У меня есть консольное приложение (потребитель). Я хочу снова использовать те же сообщения при повторном запуске приложения. Я установил: EnableAutoCommit = false, но каждый раз, когда я перезапускаю приложение, обработка сообщений занимает почти 1 минуту, почему так долго?

using Confluent.Kafka;

var config = new ConsumerConfig
{
BootstrapServers = "...",
SaslUsername = "....",
SaslPassword = "....",
SecurityProtocol = SecurityProtocol.SaslSsl,
SaslMechanism = SaslMechanism.Plain,
GroupId = "kafka-dotnet-getting-started",
AutoOffsetReset = AutoOffsetReset.Earliest,
EnableAutoCommit = false
};

const string topic = "purchases";

CancellationTokenSource cts = new CancellationTokenSource();
Console.CancelKeyPress += (_, e) => {
e.Cancel = true;
cts.Cancel();
};

Console.WriteLine($"Application start time: {DateTime.Now}");

using (var consumer = new ConsumerBuilder(config).Build())
{
consumer.Subscribe(topic);
try
{
while (true)
{
var cr = consumer.Consume(cts.Token);
Console.WriteLine($"Consumed at {DateTime.Now} event from topic {topic}: key = {cr.Message.Key,-10} value = {cr.Message.Value}");
}
}
catch (OperationCanceledException)
{
// Ctrl-C was pressed.
}
finally
{
consumer.Close();
}
}


Подробнее здесь: https://stackoverflow.com/questions/785 ... n-using-ap