RmBus.Kafka 7.0.2

# RmBus.Kafka

Description

RMBus is a developer-focused, modern platform for creating distributed applications without complexity,library. - Write once, then deploy using RabbitMQ, Azure Service Bus, and Kafka

sample usage source:

register service in Program.cs

   builder.Services.AddRmServiceBus(x => x.UseKafka(new KafkaSetting { BootstrapServers = "localhost:9092" }));

produce message

   [ApiController]
   public class WeatherForecastController(IRMProducer producer) : ControllerBase
   {   
       [HttpGet]
       public async Task<IActionResult> GetAsync()
       {
           await producer.Publish(new Company("ddd", "salt"));
           await producer.Publish(new Product() { Id = 100, Name = "prod1", Price = 44 });
           await producer.Publish("sddds");
   
           return Ok();
       }
   }

subscribe message

   public class Consumer1 : IRMConsumer<Product>
   {
       public async Task On(Product message)
       {

       }
   }

   public class Consumer2 : IRMConsumer<Company>
   {
       public async Task On(Company message)
       {

       }
   }
   public class Consumer3 : IRMConsumer<Company>
   {
       public async Task On(Company message)
       {

       }
   }

   public class Consumer4 : IRMConsumer<string>
   {
       public async Task On(string message)
       {

       }
   }

Done