在好例子网,分享、交流、成长!
您当前所在位置:首页Others 开发实例一般编程问题 → Confluent.Kafka源代码+Test

Confluent.Kafka源代码+Test

一般编程问题

下载此实例
  • 开发语言:Others
  • 实例大小:0.31M
  • 下载次数:15
  • 浏览次数:375
  • 发布时间:2020-07-31
  • 实例类别:一般编程问题
  • 发 布 人:robot666
  • 文件格式:.zip
  • 所需积分:2
 

实例介绍

【实例简介】
Confluent.Kafka源代码 测试单元 Confluent.kafka是一款C#客户端的kafka API
【实例截图】
【核心代码】
confluent-kafka-dotnet-master
└── confluent-kafka-dotnet-master
├── appveyor.yml
├── Confluent.Kafka.sln
├── confluent_logo.png
├── doc
│   ├── docfx.json
│   └── template
│   ├── partials
│   │   └── navbar.tmpl.partial
│   └── styles
│   └── main.css
├── examples
│   ├── AdvancedConsumer
│   │   ├── AdvancedConsumer.csproj
│   │   └── Program.cs
│   ├── AdvancedProducer
│   │   ├── AdvancedProducer.csproj
│   │   └── Program.cs
│   ├── AvroGeneric
│   │   ├── AvroGeneric.csproj
│   │   └── Program.cs
│   ├── AvroSpecific
│   │   ├── AvroSpecific.csproj
│   │   ├── Program.cs
│   │   ├── User.asvc
│   │   └── User.cs
│   ├── ConfluentCloud
│   │   ├── ConfluentCloud.csproj
│   │   └── Program.cs
│   ├── FSharp
│   │   ├── FSharp.fsproj
│   │   └── Program.fs
│   ├── Misc
│   │   ├── Misc.csproj
│   │   └── Program.cs
│   ├── MultiProducer
│   │   ├── MultiProducer.csproj
│   │   └── Program.cs
│   ├── SimpleConsumer
│   │   ├── Program.cs
│   │   └── SimpleConsumer.csproj
│   └── SimpleProducer
│   ├── Program.cs
│   └── SimpleProducer.csproj
├── LICENSE
├── Makefile
├── README.md
├── src
│   ├── Confluent.Kafka
│   │   ├── BrokerMetadata.cs
│   │   ├── CommittedOffsets.cs
│   │   ├── Confluent.Kafka.csproj
│   │   ├── Confluent.Kafka.snk
│   │   ├── Consumer.cs
│   │   ├── ErrorCode.cs
│   │   ├── Error.cs
│   │   ├── GroupInfo.cs
│   │   ├── GroupMemberInfo.cs
│   │   ├── IDeliveryHandler.cs
│   │   ├── Ignore.cs
│   │   ├── Impl
│   │   │   ├── LibRdKafka.cs
│   │   │   ├── Metadata.cs
│   │   │   ├── NativeMethods
│   │   │   │   ├── NativeMethods.cs
│   │   │   │   └── NativeMethods_Debian9.cs
│   │   │   ├── SafeConfigHandle.cs
│   │   │   ├── SafeHandleZeroIsInvalid.cs
│   │   │   ├── SafeKafkaHandle.cs
│   │   │   ├── SafeTopicConfigHandle.cs
│   │   │   └── SafeTopicHandle.cs
│   │   ├── include_docs.xml
│   │   ├── Internal
│   │   │   ├── Extensions
│   │   │   │   ├── String.cs
│   │   │   │   └── TimeSpan.cs
│   │   │   └── Util.cs
│   │   ├── ISerializingProducer.cs
│   │   ├── KafkaException.cs
│   │   ├── Library.cs
│   │   ├── Loggers.cs
│   │   ├── LogMessage.cs
│   │   ├── Message.cs
│   │   ├── Metadata.cs
│   │   ├── Null.cs
│   │   ├── Offset.cs
│   │   ├── PartitionMetadata.cs
│   │   ├── Producer.cs
│   │   ├── Serialization
│   │   │   ├── ByteArrayDeserializer.cs
│   │   │   ├── ByteArraySerializer.cs
│   │   │   ├── DoubleDeserializer.cs
│   │   │   ├── DoubleSerializer.cs
│   │   │   ├── Extensions
│   │   │   │   └── Message.cs
│   │   │   ├── FloatDeserializer.cs
│   │   │   ├── FloatSerializer.cs
│   │   │   ├── IDeserializer.cs
│   │   │   ├── IgnoreDeserializer.cs
│   │   │   ├── IntDeserializer.cs
│   │   │   ├── IntSerializer.cs
│   │   │   ├── ISerializer.cs
│   │   │   ├── LongDeserializer.cs
│   │   │   ├── LongSerializer.cs
│   │   │   ├── NullDeserializer.cs
│   │   │   ├── NullSerializer.cs
│   │   │   ├── StringDeserializer.cs
│   │   │   └── StringSerializer.cs
│   │   ├── Timestamp.cs
│   │   ├── TimestampType.cs
│   │   ├── TopicMetadata.cs
│   │   ├── TopicPartition.cs
│   │   ├── TopicPartitionError.cs
│   │   ├── TopicPartitionOffset.cs
│   │   ├── TopicPartitionOffsetError.cs
│   │   ├── TopicPartitionTimestamp.cs
│   │   └── WatermarkOffsets.cs
│   ├── Confluent.Kafka.Avro
│   │   ├── AvroDeserializer.cs
│   │   ├── AvroSerializer.cs
│   │   ├── Confluent.Kafka.Avro.csproj
│   │   ├── Constants.cs
│   │   ├── GenericDeserializerImpl.cs
│   │   ├── GenericSerializerImpl.cs
│   │   ├── IAvroDeserializerImpl.cs
│   │   ├── IAvroSerializerImpl.cs
│   │   ├── SpecificDeserializerImpl.cs
│   │   ├── SpecificSerializerImpl.cs
│   │   └── Utils.cs
│   └── Confluent.SchemaRegistry
│   ├── CachedSchemaRegistryClient.cs
│   ├── Confluent.SchemaRegistry.csproj
│   ├── include_docs.xml
│   ├── ISchemaRegistryClient.cs
│   ├── Rest
│   │   ├── DataContracts
│   │   │   ├── CompatibilityCheck.cs
│   │   │   ├── Compatibility.cs
│   │   │   ├── Config.cs
│   │   │   ├── ErrorMessage.cs
│   │   │   ├── Schema.cs
│   │   │   ├── SchemaId.cs
│   │   │   └── SchemaString.cs
│   │   ├── IRestService.cs
│   │   ├── RestService.cs
│   │   └── Versions.cs
│   └── SchemaRegistryException.cs
└── test
├── Confluent.Kafka.Avro.IntegrationTests
│   ├── Confluent.Kafka.Avro.IntegrationTests.csproj
│   ├── test.parameters.json
│   ├── Tests
│   │   ├── AutoRegisterSchemaDisabled.cs
│   │   ├── ConsumeIncompatibleTypes.cs
│   │   ├── PrimitiveTypes.cs
│   │   ├── ProduceConsume.cs
│   │   ├── ProduceConsumeGeneric.cs
│   │   ├── ProduceIncompatibleTypes.cs
│   │   ├── SharedSchemaRegistryClient.cs
│   │   └── Tests.cs
│   └── User.cs
├── Confluent.Kafka.Avro.UnitTests
│   ├── Configuration.cs
│   ├── Confluent.Kafka.Avro.UnitTests.csproj
│   ├── SerializeDeserialize.cs
│   └── User.cs
├── Confluent.Kafka.Benchmark
│   ├── BenchmarkConsumer.cs
│   ├── BenchmarkProducer.cs
│   ├── Confluent.Kafka.Benchmark.csproj
│   └── Program.cs
├── Confluent.Kafka.IntegrationTests
│   ├── bootstrap-topics.sh
│   ├── Confluent.Kafka.IntegrationTests.csproj
│   ├── kafka.parameters.json
│   ├── Tests
│   │   ├── AddBroker.cs
│   │   ├── AssignOverloads.cs
│   │   ├── AssignPastEnd.cs
│   │   ├── ClosedHandle.cs
│   │   ├── Consumer_OffsetsForTimes.cs
│   │   ├── Consumer_Pause_Resume.cs
│   │   ├── Consumer_Seek.cs
│   │   ├── Consumer_StoreOffsets.cs
│   │   ├── DeserializingConsumer_Consume.cs
│   │   ├── DeserializingConsumer_Poll.cs
│   │   ├── DeserializingConsumer_Poll_Error.cs
│   │   ├── DuplicateConsumerAssign.cs
│   │   ├── GarbageCollect.cs
│   │   ├── Ignore.cs
│   │   ├── ListGroup.cs
│   │   ├── Metadata.cs
│   │   ├── NullVsEmpty.cs
│   │   ├── OnLog.cs
│   │   ├── OnPartitionsAssignedNotSet.cs
│   │   ├── Producer_ProduceAsync_Await.cs
│   │   ├── Producer_ProduceAsync_DeliveryHandler.cs
│   │   ├── Producer_ProduceAsync_Null_DeliveryHandler.cs
│   │   ├── Producer_ProduceAsync_Null_Task.cs
│   │   ├── Producer_ProduceAsync_Task.cs
│   │   ├── SerializingProducer_ProduceAsync_Await.cs
│   │   ├── SerializingProducer_ProduceAsync_DeliveryHandler.cs
│   │   ├── SerializingProducer_ProduceAsync_Null_DeliveryHandler.cs
│   │   ├── SerializingProducer_ProduceAsync_Null_Task.cs
│   │   ├── SerializingProducer_ProduceAsync_Task.cs
│   │   ├── SimpleProduceConsume.cs
│   │   ├── Tests.cs
│   │   ├── __TODO.txt
│   │   └── WatermarkOffsets.cs
│   └── Util.cs
├── Confluent.Kafka.StrongName.UnitTests
│   ├── Confluent.Kafka.StrongName.UnitTests.csproj
│   ├── Confluent.Kafka.StrongName.UnitTests.snk
│   └── README.md
├── Confluent.Kafka.UnitTests
│   ├── BrokerMetadata.cs
│   ├── CommittedOffsets.cs
│   ├── Confluent.Kafka.UnitTests.csproj
│   ├── Consumer.cs
│   ├── Error.cs
│   ├── GroupInfo.cs
│   ├── GroupMemberInfo.cs
│   ├── InvalidHandle.cs
│   ├── Library.cs
│   ├── LogMessage.cs
│   ├── Message.cs
│   ├── Metadata.cs
│   ├── Offset.cs
│   ├── PartitionMetadata.cs
│   ├── Serialization
│   │   ├── ByteArray.cs
│   │   ├── Double.cs
│   │   ├── Float.cs
│   │   ├── Int.cs
│   │   ├── Long.cs
│   │   └── String.cs
│   ├── Timestamp.cs
│   ├── TopicMetadata.cs
│   ├── TopicPartition.cs
│   ├── TopicPartitionError.cs
│   ├── TopicPartitionOffset.cs
│   ├── TopicPartitionOffsetError.cs
│   ├── TopicPartitionTimestamp.cs
│   └── WatermarkOffsets.cs
├── Confluent.Kafka.VerifiableClient
│   ├── Confluent.Kafka.VerifiableClient.csproj
│   ├── globals.json
│   └── Program.cs
├── Confluent.SchemaRegistry.IntegrationTests
│   ├── Confluent.SchemaRegistry.IntegrationTests.csproj
│   ├── schema.registry.parameters.json
│   └── Tests
│   ├── FillTheCache.cs
│   ├── GetAllSubjects.cs
│   ├── GetId.cs
│   ├── GetLatestSchema.cs
│   ├── GetSchemaById.cs
│   ├── GetSchemaBySubjectAndVersion.cs
│   ├── IsCompatible.cs
│   ├── RegisterIncompatibleSchema.cs
│   ├── RegisterSameSchemaTwice.cs
│   └── Tests.cs
└── Confluent.SchemaRegistry.UnitTests
├── CachedSchemaRegistryClient.cs
├── Confluent.SchemaRegistry.UnitTests.csproj
└── Schema.cs

42 directories, 224 files

标签:

实例下载地址

Confluent.Kafka源代码+Test

不能下载?内容有错? 点击这里报错 + 投诉 + 提问

好例子网口号:伸出你的我的手 — 分享

网友评论

发表评论

(您的评论需要经过审核才能显示)

查看所有0条评论>>

小贴士

感谢您为本站写下的评论,您的评论对其它用户来说具有重要的参考价值,所以请认真填写。

  • 类似“顶”、“沙发”之类没有营养的文字,对勤劳贡献的楼主来说是令人沮丧的反馈信息。
  • 相信您也不想看到一排文字/表情墙,所以请不要反馈意义不大的重复字符,也请尽量不要纯表情的回复。
  • 提问之前请再仔细看一遍楼主的说明,或许是您遗漏了。
  • 请勿到处挖坑绊人、招贴广告。既占空间让人厌烦,又没人会搭理,于人于己都无利。

关于好例子网

本站旨在为广大IT学习爱好者提供一个非营利性互相学习交流分享平台。本站所有资源都可以被免费获取学习研究。本站资源来自网友分享,对搜索内容的合法性不具有预见性、识别性、控制性,仅供学习研究,请务必在下载后24小时内给予删除,不得用于其他任何用途,否则后果自负。基于互联网的特殊性,平台无法对用户传输的作品、信息、内容的权属或合法性、安全性、合规性、真实性、科学性、完整权、有效性等进行实质审查;无论平台是否已进行审查,用户均应自行承担因其传输的作品、信息、内容而可能或已经产生的侵权或权属纠纷等法律责任。本站所有资源不代表本站的观点或立场,基于网友分享,根据中国法律《信息网络传播权保护条例》第二十二与二十三条之规定,若资源存在侵权或相关问题请联系本站客服人员,点此联系我们。关于更多版权及免责申明参见 版权及免责申明

;
报警