PartitionCache 持久性生产者分区缓存
PartitionCache :拆分您的工作负载PartitionCache是一个简单的持久化生产者分区缓存。这意味着什么?嗯,这意味着它会记住生产者属于哪个分区,并允许您将工作负载分成多个分区,以避免任何多线程问题或并发问题。 PartitionCache不存储任何需要处理的事件或项目,而是充当每个项目所属分区号的持久存储。基本原理PartitionCache填补了持久Dictionary的空白,其中int是分区,string是生产者的名称。这允许生产者或唯一键在其生命周期内为它们分配一个持久的唯一整数。 PartitionCache为您提供便利,并允许您对代码进行建模,以最终迁移到Kafka、Azure事件中心或Amazon Kinesis。我正在使用PartitionCache来提供一个非常轻量级的Kafka,如
下载地址
用户评论