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}]
评论信息
其他资源
- director11.5 反编译器
- 用于kinetis解锁的cmd文件
- 小型超市管理系统.zip
- 基于Android仿QQ聊天系统毕业设计论文(含源码)
- msvcr120.zip
- 简单网页作业+二级页面
- 模糊聚类matlab程序
- 基于小波变换的matlab图像处理程序
- 小波变换的图像去噪的matlab程序的源代码
- KEIL5安装包以及破解文件.zip
- 连锁店管理系统c#（含数据库）
- JSP个人记帐系统 毕业设计
- 提升小波变换的matlab程序
- java源码.zip
- 2021短视频营销攻略报告.pdf
- 中国文化要略复习笔记.pdf
- K10Stat091 (1).zip.9quoixb.partial
- 思科2504升级固件AIR-CT2500-K9-8-2-151-0.aes
- 2018-11gOCP题库全
- 良精通用企业网站管理系统
- PHP Manager for IIS Windows2008 x64位
- 串口网口透传映射源码基于arm-mx335
- python儿童编程
- 锅炉原理课程设计程序
- R树的java版本实现
免责申明
【只为小站】的资源来自网友分享，仅供学习研究，请务必在下载后24小时内给予删除，不得用于其他任何用途，否则后果自负。基于互联网的特殊性，【只为小站】 无法对用户传输的作品、信息、内容的权属或合法性、合规性、真实性、科学性、完整权、有效性等进行实质审查；无论 【只为小站】 经营者是否已进行审查，用户均应自行承担因其传输的作品、信息、内容而可能或已经产生的侵权或权属纠纷等法律责任。
本站所有资源不代表本站的观点或立场，基于网友分享，根据中国法律《信息网络传播权保护条例》第二十二条之规定，若资源存在侵权或相关问题请联系本站客服人员，zhiweidada#qq.com，请把#换成@，本站将给予最大的支持与配合，做到及时反馈和处理。关于更多版权及免责申明参见 版权及免责申明
本站所有资源不代表本站的观点或立场，基于网友分享，根据中国法律《信息网络传播权保护条例》第二十二条之规定，若资源存在侵权或相关问题请联系本站客服人员，zhiweidada#qq.com，请把#换成@，本站将给予最大的支持与配合，做到及时反馈和处理。关于更多版权及免责申明参见 版权及免责申明