实例介绍
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
标签:
相关软件
小贴士
感谢您为本站写下的评论,您的评论对其它用户来说具有重要的参考价值,所以请认真填写。
- 类似“顶”、“沙发”之类没有营养的文字,对勤劳贡献的楼主来说是令人沮丧的反馈信息。
- 相信您也不想看到一排文字/表情墙,所以请不要反馈意义不大的重复字符,也请尽量不要纯表情的回复。
- 提问之前请再仔细看一遍楼主的说明,或许是您遗漏了。
- 请勿到处挖坑绊人、招贴广告。既占空间让人厌烦,又没人会搭理,于人于己都无利。
关于好例子网
本站旨在为广大IT学习爱好者提供一个非营利性互相学习交流分享平台。本站所有资源都可以被免费获取学习研究。本站资源来自网友分享,对搜索内容的合法性不具有预见性、识别性、控制性,仅供学习研究,请务必在下载后24小时内给予删除,不得用于其他任何用途,否则后果自负。基于互联网的特殊性,平台无法对用户传输的作品、信息、内容的权属或合法性、安全性、合规性、真实性、科学性、完整权、有效性等进行实质审查;无论平台是否已进行审查,用户均应自行承担因其传输的作品、信息、内容而可能或已经产生的侵权或权属纠纷等法律责任。本站所有资源不代表本站的观点或立场,基于网友分享,根据中国法律《信息网络传播权保护条例》第二十二与二十三条之规定,若资源存在侵权或相关问题请联系本站客服人员,点此联系我们。关于更多版权及免责申明参见 版权及免责申明
网友评论
我要评论