c# kafka生产者发送消息
时间: 2024-01-16 21:18:11 浏览: 41
在C#中使用Kafka生产者发送消息的示例代码如下:
```csharp
using Confluent.Kafka;
using System;
class Program
{
static void Main(string[] args)
{
var config = new ProducerConfig
{
BootstrapServers = "localhost:9092", // Kafka集群的地址和端口
ClientId = "csharp-producer" // 客户端ID
};
using (var producer = new ProducerBuilder<Null, string>(config).Build())
{
string topic = "my-topic"; // 指定要发送消息的主题
// 构造消息
var message = new Message<Null, string>
{
Value = "Hello Kafka!" // 消息内容
};
try
{
// 发送消息
var result = producer.ProduceAsync(topic, message).GetAwaiter().GetResult();
Console.WriteLine($"消息发送成功,分区:{result.Partition}, 偏移量:{result.Offset}");
}
catch (ProduceException<Null, string> ex)
{
Console.WriteLine($"消息发送失败:{ex.Error.Reason}");
}
}
}
}
```
请注意,上述代码中使用了Confluent.Kafka库,确保你已经安装了该库。你可以使用NuGet包管理器或者在Visual Studio中通过右键点击项目,选择"Manage NuGet Packages"来安装该库。