Kafka的C#客户端源码下载

【实例简介】
kafka-net项目是针对Apache Kafka的原生C#客户端实现。它基于kafka-python库的协议部分，并尝试遵循类似的总体类布局。该项目从处理异步请求的低级KafkaConnection对象开始，一直构建到更高级的Producer/Consumer类。

示例：

var options = new KafkaOptions(new Uri("http://SERVER1:9092"), new Uri("http://SERVER2:9092"));
var router = new BrokerRouter(options);
var client = new Producer(router);

client.SendMessageAsync("TestHarness", new[] { new Message("hello world")}).Wait();

using (client) { }

var options = new KafkaOptions(new Uri("http://SERVER1:9092"), new Uri("http://SERVER2:9092"));
var router = new BrokerRouter(options);
var consumer = new Consumer(new ConsumerOptions("TestHarness", router));

foreach (var message in consumer.Consume())
{
    Console.WriteLine("Response: P{0},O{1} : {2}", 
        message.Meta.PartitionId, message.Meta.Offset, message.Value);  
}

该项目是一个正在进行中的作品，包含完整的Producer和Consumer类，因此可以实现与Kafka服务器的消息传递。目前，该项目支持.NET Framework 4.5，并且仅实现了Gzip压缩。
【实例截图】
【核心代码】
文件清单
└── kafka-net-c9bbbe61fd519da5a8a7fcb99035bf2cbc5940d3
    ├── LICENSE
    ├── README.md
    └── src
        ├── kafka-net
        │   ├── BrokerRouter.cs
        │   ├── Common
        │   │   ├── AsyncCollection.cs
        │   │   ├── AsyncLock.cs
        │   │   ├── AsyncManualResetEvent.cs
        │   │   ├── BigEndianBinaryReader.cs
        │   │   ├── BigEndianBinaryWriter.cs
        │   │   ├── ConcurrentCircularBuffer.cs
        │   │   ├── Crc32Provider.cs
        │   │   ├── Extensions.cs
        │   │   ├── KafkaMessagePacker.cs
        │   │   └── ScheduledTimer.cs
        │   ├── Consumer.cs
        │   ├── Default
        │   │   ├── ConsoleLog.cs
        │   │   ├── DefaultKafkaConnectionFactory.cs
        │   │   ├── DefaultPartitionSelector.cs
        │   │   └── DefaultTraceLog.cs
        │   ├── Interfaces
        │   │   ├── IBrokerRouter.cs
        │   │   ├── IKafkaConnection.cs
        │   │   ├── IKafkaConnectionFactory.cs
        │   │   ├── IKafkaLog.cs
        │   │   ├── IKafkaRequest.cs
        │   │   ├── IKafkaTcpSocket.cs
        │   │   ├── IMetadataQueries.cs
        │   │   └── IPartitionSelector.cs
        │   ├── KafkaConnection.cs
        │   ├── KafkaMetadataProvider.cs
        │   ├── kafka-net.csproj
        │   ├── kafka-net.nuspec
        │   ├── KafkaTcpSocket.cs
        │   ├── MetadataQueries.cs
        │   ├── Model
        │   │   ├── BrokerRoute.cs
        │   │   ├── ConsumerOptions.cs
        │   │   ├── KafkaEndpoint.cs
        │   │   └── KafkaOptions.cs
        │   ├── Producer.cs
        │   ├── Properties
        │   │   └── AssemblyInfo.cs
        │   ├── Protocol
        │   │   ├── BaseRequest.cs
        │   │   ├── Broker.cs
        │   │   ├── ConsumerMetadataRequest.cs
        │   │   ├── FetchRequest.cs
        │   │   ├── Message.cs
        │   │   ├── MetadataRequest.cs
        │   │   ├── OffsetCommitRequest.cs
        │   │   ├── OffsetFetchRequest.cs
        │   │   ├── OffsetRequest.cs
        │   │   ├── ProduceRequest.cs
        │   │   ├── Protocol.cs
        │   │   └── Topic.cs
        │   └── Statistics
        │       └── StatisticsTracker.cs
        ├── kafka-net.nuspec
        ├── kafka-net.sln
        ├── kafka-tests
        │   ├── App.config
        │   ├── Fakes
        │   │   ├── BrokerRouterProxy.cs
        │   │   ├── FakeBrokerRouter.cs
        │   │   ├── FakeKafkaConnection.cs
        │   │   └── FakeTcpServer.cs
        │   ├── Helpers
        │   │   ├── IntegrationConfig.cs
        │   │   ├── MessageHelper.cs
        │   │   └── TaskTest.cs
        │   ├── Integration
        │   │   ├── GzipProducerConsumerTests.cs
        │   │   ├── KafkaConnectionIntegrationTests.cs
        │   │   ├── KafkaMetadataProviderUnitTests.cs
        │   │   ├── OffsetManagementTests.cs
        │   │   ├── ProducerConsumerIntegrationTests.cs
        │   │   └── ProducerIntegrationTests.cs
        │   ├── kafka-tests.csproj
        │   ├── packages.config
        │   ├── Properties
        │   │   └── AssemblyInfo.cs
        │   ├── RequestFactory.cs
        │   └── Unit
        │       ├── AsyncCollectionTests.cs
        │       ├── AsyncLockTests.cs
        │       ├── BigEndianBinaryReaderTests.cs
        │       ├── BigEndianBinaryWriterTests.cs
        │       ├── BrokerRouterTests.cs
        │       ├── CircularBufferTests.cs
        │       ├── ConsumerTests.cs
        │       ├── DefaultPartitionSelectorTests.cs
        │       ├── FakeTcpServerTests.cs
        │       ├── KafkaConnectionTests.cs
        │       ├── KafkaEndpointTests.cs
        │       ├── KafkaMetadataProviderTests.cs
        │       ├── KafkaTcpSocketTests.cs
        │       ├── MetadataQueriesTests.cs
        │       ├── ProducerTests.cs
        │       ├── ProtocolBaseRequestTests.cs
        │       ├── ProtocolMessageTests.cs
        │       ├── ProtocolTests.cs
        │       └── ScheduleTimerTests.cs
        ├── StatisticsTestLoader
        │   ├── Configuration.cs
        │   ├── ConsoleLogger.cs
        │   ├── DestinationKafka.cs
        │   ├── IRecordSource.cs
        │   ├── KafkaRecord.cs
        │   ├── packages.config
        │   ├── Program.cs
        │   ├── Properties
        │   │   └── AssemblyInfo.cs
        │   ├── SourcePropertyChanges.cs
        │   └── StatisticsTestLoader.csproj
        └── TestHarness
            ├── App.config
            ├── packages.config
            ├── Program.cs
            ├── Properties
            │   └── AssemblyInfo.cs
            └── TestHarness.csproj

20 directories, 105 files