文件名称：Orleans.Streams.Kafka:使用Confluent API为Microsoft Orleans和Kafka实现PersistentStreamProvider的实现
文件大小：95KB
文件格式：ZIP
更新时间：2024-05-30 13:00:25
kafka avro schema-registry streams confluent
奥尔良流卡夫卡 使用Microsoft Orleans的Kafka持久流提供程序。 该提供程序的另一个好处是，它允许将外部消息（不是由olreans生成）与orleans流系统合并，就像消息是由orleans生成一样。 依存关系 Orleans.Streams.Kafka具有以下依赖项： 微软奥尔良3.2.0 卡夫卡汇合： 1.4.3 Orleans.Streams.Utils： 安装 要开始使用Orleans.Streams.Kafka确保执行以下步骤： 在您有权使用的机器（或集群）上安装Kafka。 在Kafka中创建主题，并根据每个主题的需要分配尽可能多的分区。 从nuget存储库安装Orleans.Streams.Kafka nuget。 将带有必需参数和可选参数（如果需要）的新流提供程序添加到Silo配置中。 您可以在下看到KafkaStreamProvider中可