Kafka Event Producer Service

event-driven-architecture-kafka-event-producer.cs

public class KafkaService : IKafkaService
{
    private readonly string saslUsername;
    private readonly string saslPassword;
    public readonly string serverAddress;

    public KafkaService(string serverAddress, string saslUsername, string saslPassword)
    {
        this.serverAddress = serverAddress;
        this.saslUsername = saslUsername;
        this.saslPassword = saslPassword;
    }

    public async Task SendMessage(string topic, string message)
    {
        if (message.IsEmpty())
        {
            throw new ArgumentNullException(nameof(message));
        }

        var config = new ProducerConfig
        {
            BootstrapServers = serverAddress,
            SecurityProtocol = SecurityProtocol.SaslSsl,
            SaslMechanism = SaslMechanism.Plain,
            SaslUsername = saslUsername,
            SaslPassword = saslPassword,
            Acks = Acks.Leader,
            CompressionType = CompressionType.Lz4,
            Debug = "security,broker,protocol"
        };

        using (var producer = new ProducerBuilder<Null, string>(config).Build())
        {
            await producer.ProduceAsync(topic, new Message<Null, string>
            {
                Value = message
            });
        }
    }
}