Kafka Utility Methods

kafka-utils.cs

public static class KafkaUtils
{
    public static IConsumer<int, string> CreateConsumer(string brokerList, List<string> topics)
    {
        var config = new ConsumerConfig
        {
            BootstrapServers = brokerList,
            GroupId = "sample-consumer"
        };
        var consumer = new ConsumerBuilder<int, string>(config).Build();
        consumer.Subscribe(topics);
        return consumer;
    }

    public static IProducer<int, string> CreateProducer(string brokerList)
    {
        var config = new ProducerConfig { BootstrapServers = brokerList };
        var producer = new ProducerBuilder<int, string>(config).Build();
        return producer;
    }
}