private readonly ILogger<KafkaConsumerHostedService> _logger;
private ClusterClient _cluster;
public KafkaConsumerHostedService(ILogger<KafkaConsumerHostedService> logger)
{
_logger = logger;
_cluster = new ClusterClient(new Configuration
{
Seeds = "localhost:9092"
}, new ConsoleLogger());
}
public Task StartAsync(CancellationToken cancellationToken)
{
_cluster.ConsumeFromLatest("demo");
_cluster.MessageReceived += record =>
{
_logger.LogInformation($"Received: {Encoding.UTF8.GetString(record.Value as byte[])}");
};
return Task.CompletedTask;
}
public Task StopAsync(CancellationToken cancellationToken)
{
_cluster?.Dispose();
return Task.CompletedTask;
}
}
Здравствуйте! Есть проблема, как мне получить _cluster.MessageReceived в другом классе ?
когда в другом классе делаю
private readonly KafkaConsumerHostedService _service;
ничего не получается. Подскажите, где я делаю ошибку.
Потому что он приватный
Обсуждают сегодня