通過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）