misakai-kafka:Misakai.Kafka 是 C# 的高性能 Apache Kafka 客户端-源码
御坂卡夫卡
用于 Apache Kafka 的高性能 C# 客户端。 该客户端旨在不支持所有可能的功能，而是为长期运行的生产者/消费者提供简约轻量级的 Kafka 客户端。 该代码基于 James Roland 的 KafkaNet 实现，经过大幅精简和优化。
构建状态：
NuGet 包：
例子
制作人
var options = new KafkaOptions ( new Uri ( " http://kafka1:9092 " ), new Uri ( " http://kafka2:9092 " ))
{
Log = new ConsoleLog ()
};
var router = new BrokerRouter ( options );
var client = new Producer ( router );
Task . Run (() =>
{
v
文件下载
资源详情
[{"title":"（ 57 个子文件 78KB ） misakai-kafka:Misakai.Kafka 是 C# 的高性能 Apache Kafka 客户端-源码","children":[{"title":"misakai-kafka-master","children":[{"title":".gitignore <span style='color:#111;'> 2.61KB </span>","children":null,"spread":false},{"title":"README.md <span style='color:#111;'> 1.20KB </span>","children":null,"spread":false},{"title":"Misakai.Kafka","children":[{"title":"Misakai.Kafka.csproj <span style='color:#111;'> 4.49KB </span>","children":null,"spread":false},{"title":"ConsumerOptions.cs <span style='color:#111;'> 1.93KB </span>","children":null,"spread":false},{"title":"Default","children":[{"title":"DefaultPartitionSelector.cs <span style='color:#111;'> 1.53KB </span>","children":null,"spread":false},{"title":"DefaultTraceLog.cs <span style='color:#111;'> 1.14KB </span>","children":null,"spread":false},{"title":"DefaultKafkaConnectionFactory.cs <span style='color:#111;'> 1.84KB </span>","children":null,"spread":false}],"spread":true},{"title":"Contracts","children":[{"title":"IMetadataQueries.cs <span style='color:#111;'> 1.01KB </span>","children":null,"spread":false},{"title":"IPartitionSelector.cs <span style='color:#111;'> 574B </span>","children":null,"spread":false},{"title":"IKafkaConnection.cs <span style='color:#111;'> 967B </span>","children":null,"spread":false},{"title":"IKafkaRequest.cs <span style='color:#111;'> 1.49KB </span>","children":null,"spread":false},{"title":"IKafkaConnectionFactory.cs <span style='color:#111;'> 1.22KB </span>","children":null,"spread":false},{"title":"IKafkaLog.cs <span style='color:#111;'> 1.89KB </span>","children":null,"spread":false},{"title":"IKafkaTcpSocket.cs <span style='color:#111;'> 1.82KB </span>","children":null,"spread":false}],"spread":true},{"title":"Binary","children":[{"title":"BinaryStream.cs <span style='color:#111;'> 6.89KB </span>","children":null,"spread":false},{"title":"BinaryReader.cs <span style='color:#111;'> 6.31KB </span>","children":null,"spread":false},{"title":"BinaryCrc32.cs <span style='color:#111;'> 3.64KB </span>","children":null,"spread":false},{"title":"BinaryHelper.cs <span style='color:#111;'> 4.64KB </span>","children":null,"spread":false}],"spread":true},{"title":"Properties","children":[{"title":"AssemblyInfo.cs <span style='color:#111;'> 646B </span>","children":null,"spread":false}],"spread":true},{"title":"KafkaOptions.cs <span style='color:#111;'> 2.38KB </span>","children":null,"spread":false},{"title":"KafkaMetadataProvider.cs <span style='color:#111;'> 7.87KB </span>","children":null,"spread":false},{"title":"Broker","children":[{"title":"IBrokerRouter.cs <span style='color:#111;'> 2.87KB </span>","children":null,"spread":false},{"title":"Broker.cs <span style='color:#111;'> 622B </span>","children":null,"spread":false},{"title":"BrokerRouter.cs <span style='color:#111;'> 12.19KB </span>","children":null,"spread":false},{"title":"BrokerRoute.cs <span style='color:#111;'> 922B </span>","children":null,"spread":false}],"spread":true},{"title":"Consumer.cs <span style='color:#111;'> 10.03KB </span>","children":null,"spread":false},{"title":"Producer.cs <span style='color:#111;'> 5.39KB </span>","children":null,"spread":false},{"title":"Network","children":[{"title":"KafkaTcpSocket.cs <span style='color:#111;'> 9.45KB </span>","children":null,"spread":false},{"title":"KafkaConnection.cs <span style='color:#111;'> 10.38KB </span>","children":null,"spread":false},{"title":"KafkaEndpoint.cs <span style='color:#111;'> 966B </span>","children":null,"spread":false}],"spread":false},{"title":"Protocol","children":[{"title":"FetchRequest.cs <span style='color:#111;'> 5.31KB </span>","children":null,"spread":false},{"title":"OffsetFetchRequest.cs <span style='color:#111;'> 4.20KB </span>","children":null,"spread":false},{"title":"ConsumerMetadataRequest.cs <span style='color:#111;'> 2.23KB </span>","children":null,"spread":false},{"title":"Topic.cs <span style='color:#111;'> 3.05KB </span>","children":null,"spread":false},{"title":"OffsetRequest.cs <span style='color:#111;'> 4.98KB </span>","children":null,"spread":false},{"title":"MetadataRequest.cs <span style='color:#111;'> 2.57KB </span>","children":null,"spread":false},{"title":"ProduceRequest.cs <span style='color:#111;'> 4.54KB </span>","children":null,"spread":false},{"title":"KafkaRequest.cs <span style='color:#111;'> 1.48KB </span>","children":null,"spread":false},{"title":"OffsetCommitRequest.cs <span style='color:#111;'> 4.38KB </span>","children":null,"spread":false},{"title":"Message.cs <span style='color:#111;'> 6.56KB </span>","children":null,"spread":false},{"title":"Protocol.cs <span style='color:#111;'> 2.82KB </span>","children":null,"spread":false}],"spread":false},{"title":"Threading","children":[{"title":"ThreadWall.cs <span style='color:#111;'> 3.53KB </span>","children":null,"spread":false},{"title":"ScheduledTimer.cs <span style='color:#111;'> 8.13KB </span>","children":null,"spread":false}],"spread":false},{"title":"MetadataQueries.cs <span style='color:#111;'> 2.99KB </span>","children":null,"spread":false}],"spread":false},{"title":"appveyor.yml <span style='color:#111;'> 577B </span>","children":null,"spread":false},{"title":"LICENSE <span style='color:#111;'> 11.05KB </span>","children":null,"spread":false},{"title":".gitattributes <span style='color:#111;'> 483B </span>","children":null,"spread":false},{"title":"Deploy","children":[{"title":"NuGet.exe <span style='color:#111;'> 18.00KB </span>","children":null,"spread":false},{"title":"pack.ps1 <span style='color:#111;'> 584B </span>","children":null,"spread":false},{"title":"Misakai.Kafka.nuspec <span style='color:#111;'> 791B </span>","children":null,"spread":false}],"spread":true},{"title":"Misakai.Kafka.sln <span style='color:#111;'> 1.67KB </span>","children":null,"spread":false},{"title":"Test","children":[{"title":"Properties","children":[{"title":"AssemblyInfo.cs <span style='color:#111;'> 1.36KB </span>","children":null,"spread":false}],"spread":true},{"title":"Program.cs <span style='color:#111;'> 2.98KB </span>","children":null,"spread":false},{"title":"ConsoleLog.cs <span style='color:#111;'> 1.07KB </span>","children":null,"spread":false},{"title":"Test.csproj <span style='color:#111;'> 4.28KB </span>","children":null,"spread":false},{"title":"App.config <span style='color:#111;'> 180B </span>","children":null,"spread":false},{"title":"RollingQueue.cs <span style='color:#111;'> 1.01KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}]
评论信息
其他资源
- EnterpriseArchitect13中文版
- freeswitch基于阿里云的的语音识别检测模块
- rgb24转yuv420高效率 完整代码，C++实现
- MATLAB时域有限差分法程序
- hec-georas105.zip
- 《JAVA程序设计》期末考试试题汇总及答案
- 拨码开关封装（三维PCB封装库）AD用PCB封装库
- linux环境下基于socket通信的ftp系统
- 中国流域数据集
- 高等概率论（英文版）课后习题答案
- HHT变换的三种方法 Matlab，包含CMD分解，希尔伯特黄方法时频分析
- bug管理系统源码
- Head First 面向对象分析与设计(中文版).pdf
- bot2ln-源码
- 互联网产品开发中的“快”字诀
- Xftp7一种灵活且轻量级的SFFT/FTP客户端
- 数据安全能力建设实施指南.docx
- navicat.zip
- KEIL4&5配色方案.rar
- Crack-Modelsim-Altera 10.1d
- 2017宁波海曙区中小学信息学竞赛复赛试题
免责申明
【只为小站】的资源来自网友分享，仅供学习研究，请务必在下载后24小时内给予删除，不得用于其他任何用途，否则后果自负。基于互联网的特殊性，【只为小站】 无法对用户传输的作品、信息、内容的权属或合法性、合规性、真实性、科学性、完整权、有效性等进行实质审查；无论 【只为小站】 经营者是否已进行审查，用户均应自行承担因其传输的作品、信息、内容而可能或已经产生的侵权或权属纠纷等法律责任。
本站所有资源不代表本站的观点或立场，基于网友分享，根据中国法律《信息网络传播权保护条例》第二十二条之规定，若资源存在侵权或相关问题请联系本站客服人员，zhiweidada#qq.com，请把#换成@，本站将给予最大的支持与配合，做到及时反馈和处理。关于更多版权及免责申明参见 版权及免责申明
本站所有资源不代表本站的观点或立场，基于网友分享，根据中国法律《信息网络传播权保护条例》第二十二条之规定，若资源存在侵权或相关问题请联系本站客服人员，zhiweidada#qq.com，请把#换成@，本站将给予最大的支持与配合，做到及时反馈和处理。关于更多版权及免责申明参见 版权及免责申明