Public class KafkaConsumerHostedService : IHostedService {

Question

Public class KafkaConsumerHostedService : IHostedService {

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;

ничего не получается. Подскажите, где я делаю ошибку.

#backend #dot #programming #russian

0

15.05.2022

1 ответов

9 просмотров

Сергей (F L ) · Accepted Answer

Сергей (F L )

Потому что он приватный

0

15.05.2022

170 похожих чатов

Public class KafkaConsumerHostedService : IHostedService {

1 ответов

Похожие вопросы