.NET Core如何实现Kafka实战教程第3部分？

本文共计1625个文字，预计阅读时间需要7分钟。

作为一名.NET开发者，自然想在自己的.NET项目中集成Kafka实现发布订阅功能。本文总结了如何通过使用对应的客户端端库，如Confluent.Kafka，结合CAP项目，方便地实现发布订阅的效果。

作为一个.NET Developer，自然想要在.NET项目中集成Kafka实现发布订阅功能。本文总结了.NET Core如何通过对应客户端操作Kafka，基于Confluent.Kafka项目和CAP项目可以方便的实现发布订阅的效果。 1 可用的Kafka .NET客户端

作为一个.NET Developer，自然想要在.NET项目中集成Kafka实现发布订阅功能。那么，目前可用的Kafka客户端有哪些呢？

目前.NET圈子主流使用的是Confluent.Kafka

confluent-kafka-dotnet:github.com/confluentinc/confluent-kafka-dotnet

其他主流的客户端还有rdkafka-dotnet项目，但是其已经被并入confluent-kakfa-dotnet项目进行维护了。

因此，推荐使用confluent-kafka-dotnet，其配置友好，功能也更全面。

NCC千星项目CAP的Kafka扩展包（DotNetCore.CAP.Kafka）内部也是基于Confluent.Kafka来实现的：

接下来，本文就来在.NET Core项目下通过Confluent.Kafka和CAP两个主流开源项目来操作一下Kafka，实现一下发布订阅的功能。

2 基于Confluent.Kafka的示例

要完成本文示例，首先得有一个启动好的Kafka Broker服务。