Apache Pulsar：使用 DotPulsar 的应用程序

Question

我构建了一个小型 NET Core 应用程序来测试 Pulsar。我正在尝试重复此处描述的步骤https://pulsar.apache.org/docs/en/client-libraries-dotnet/ 我已经添加了 NuGet DotPulsar。

而且我在编译过程中遇到了错误。 例如， var data = Encoding.UTF8.GetBytes("Hello World"); var messageId = 等待 pulsarProducer.NewMessage() .Property("SomeKey", "SomeValue") .发送（数据）；

IProducer 不包含 NewMessage() 等的定义。如何解决？

Answer 1

IProducer 上的 'NewMessage' 方法实际上是一个扩展方法，所以你需要一个 'DotPulsar.Extensions' 的 using 语句。

最好的问候 分贝