Consume всегда возвращает ноль ⇐ C#

[Anonymous]

Я новичок в использовании Kafka и столкнулся с проблемой, из-за которой Consume всегда возвращает значение null.
В настройках я пробовал использовать как Earlyest, так и Latest. В теме появляются новые сообщения, но мое приложение всегда получает null. В чем может быть проблема?
Вот мой код
public KafkaHostedService(IConfiguration configuration, IServiceProvider serviceProvider)
{
var kafkaConfig = new ConsumerConfig
{
BootstrapServers = configuration["Kafka:BootstrapServers"],
GroupId = configuration["Kafka:GroupId"],
AutoOffsetReset = AutoOffsetReset.Latest
};
_consumer = new ConsumerBuilder(kafkaConfig).Build();
_consumer.Subscribe(configuration["Kafka:Topic"]);
_serviceProvider = serviceProvider;
_keyToFetch = configuration["Kafka:KeyToFetch"] ?? throw new ArgumentNullException("Kafka:KetToFetch не задан")
}

private async Task ConsumeMessages(CancellationToken stoppingToken)
{

while (!stoppingToken.IsCancellationRequested)
{
try
{
Console.WriteLine("Запуск потребителя");
var result = _consumer.Consume(TimeSpan.FromSeconds(1));

if (result == null)
{
Console.WriteLine("No messages found");
}

if (result != null && result.Message != null)
{
Console.WriteLine("Messages found!");
}
}
catch (OperationCanceledException)
{

break;
}
catch (Exception ex)
{
Console.WriteLine($"Error: {ex.Message}");
}
}


Подробнее здесь: https://stackoverflow.com/questions/793 ... turns-null