如何在 C# 代码中使用 Amazon MSK 将消息发布到 Kafka

Question

我正在创建 ac# 应用程序来向 Kafka 发布消息。在我的应用程序的当前版本中，我使用 docker（confluenceinc-cp 和 confluenceinc-zookeeper）在本地设置集群。然而，为了高效运行 Kafka，我们决定使用 Managed Streaming Apache Kafka (MSK) 来运行云原生 kafka 集群。我们的数据工程团队已经创建了一个集群。已经有一个专用网络（引导服务器）的端点和 Zookeeper 的明文 url。

如何更改 ProducerConfig 以使用 MSK 而不是 localhost

我的生产者代码如下所示：

public class ProducerHostedService : IHostedService
{
    private readonly ILogger<ProducerHostedService> _logger;
    private readonly IProducer<Null, string> _producer;

    public ProducerHostedService(ILogger<ProducerHostedService> logger)
    {
        _logger = logger;
        var config = new ProducerConfig
        {
            //SecurityProtocol = SecurityProtocol.Ssl,
            
            BootstrapServers = "localhost:9092"
        };
        _producer = new ProducerBuilder<Null, string>(config).Build();
    }
    
    public async Task StartAsync(CancellationToken cancellationToken)
    {
        for (var i = 0; i < 100; ++i)
        {
          var order = new OrderRequest()
                      {
                          CustomerId = i,
                          ProductId = i,
                          OrderId = i,
                          Quantity = 1,
                          Status = "New"
                      };
            string message = JsonSerializer.Serialize(order);
            _logger.LogInformation(message);
            // ProduceAsync creates a topic if not exists
            await _producer.ProduceAsync("test", new Message<Null, string>()
            {
                Value = message
            }, cancellationToken);
        }

        _producer.Flush(TimeSpan.FromSeconds(10));
    }

    public Task StopAsync(CancellationToken cancellationToken)
    {
        _producer?.Dispose();
        return Task.CompletedTask;
    }
}