Confluent.Kafka源代码+Test

【实例简介】
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