👁 Image
Yottadem.Kafka.Producer.Sdk 1.1.1

Yottadem Kafka Producer SDK

A lightweight and scalable Kafka Producer SDK for .NET applications developed by Yottadem Tech Solutions.

Author

Yottadem Tech Solutions

Company

Yottadem Tech Solutions

Features

• Simple Kafka producer setup
• Multi-host Kafka configuration support
• Dependency Injection support
• Async message production
• Supports .NET 6 and .NET 8
• Built with Akka Streams Kafka

Installation

Install the package using NuGet Package Manager:

Install-Package Yottadem.Kafka.Producer.Sdk

Or using the .NET CLI:

dotnet add package Yottadem.Kafka.Producer.Sdk

Configuration

Add the following configuration to your appsettings.json file:

{
 "KafkaProducerConfig": {
 "Hosts": [
 {
 "BootstrapServers": "localhost:9092",
 "Alias": "ecommerce-kafka",
 "SecurityProtocol": "SASL_SSL",
 "SaslMechanism": "PLAIN",
 "SaslUsername": "API-Key",
 "SaslPassword": "API-Secret"
 },
 {
 "BootstrapServers": "localhost:9092",
 "Alias": "general-kafka-2",
 "SecurityProtocol": "SASL_SSL",
 "SaslMechanism": "PLAIN",
 "SaslUsername": "API-Key",
 "SaslPassword": "API-Secret"
 }
 ]
 }
}

Service Registration

Register the SDK in Program.cs or Startup.cs:

services.AddYottademKafkaProducerSdk(config =>
 Configuration.GetSection(nameof(KafkaProducerConfig)).Bind(config));

Usage

Inject IKafkaProducerFactory into your service and create a Kafka producer instance.

public class ProduceToKafkaService
{
 private readonly IKafkaProducer _producer;

 public ProduceToKafkaService(IKafkaProducerFactory producerFactory)
 {
 _producer = producerFactory.CreateKafkaProducer("general-kafka");
 }

 public async Task ProduceToKafka(object data)
 {
 await _producer.ProduceAsync("test.topic", data);
 }
}

Supported Frameworks

• .NET 8

License

This project is licensed under the MIT License.

Maintained By

Yottadem Tech Solutions