通过Confluent.kafka实现C#下使用Kafka(一)---生产者

通过Confluent.Kafka.dll在.net core下使用Kafka

1.在项目中安装Confluent.Kafka的Nuget包

2.添加生产者

  /// <summary>
    /// Kafka消息生产者
    /// </summary>
    public class KafkaProducer
    {
        public static string brokerUrl = "localhost:9092";
        public static string topic = "TestTopic";
        private static readonly object Locker = new object();
        private static IProducer<string, string> _producer;
        /// <summary>
        /// 单例生产
        /// </summary>
        public KafkaProducer()
        {
            if (_producer == null)
            {
                lock (Locker)
                {
                    if (_producer == null)
                    {
                        var config = new ProducerConfig
                        {
                            BootstrapServers = brokerUrl
                        };
                        _producer = new ProducerBuilder<string, string>(config).Build();
                    }
                }
            }
        }
 
        /// <summary>
        /// 生产消息并发送消息
        /// </summary>
        /// <param name="key">key</param>
        /// <param name="message">需要传送的消息</param>
        public static void Produce(string key, string message)
        {
            bool result = false;
            new KafkaProducer();
            if (string.IsNullOrEmpty(message) || string.IsNullOrWhiteSpace(message) || message.Length <= 0)
            {
                throw new ArgumentNullException("消息内容不能为空！");
            }
            _producer.Produce(topic, new Message<string, string> { Key = key, Value = message });
            _producer.Flush(TimeSpan.FromSeconds(10));
        }
    }

外部调用Produce方法即可产生消息

 

参考文档：

https://blog.csdn.net/qq_23009105/article/details/87993827（C#实现kafka消息队列-Confluent.Kafka）

https://zhuanlan.zhihu.com/p/139101754（c#操作kafka（下）使用confluent.kafka）