ExactTargetDev · orthrus · Dec 18, 2015 · Dec 18, 2015 · Dec 29, 2015 · Dec 29, 2015
diff --git a/lib/log4Net/log4net.dll b/lib/log4Net/log4net.dll
diff --git a/lib/log4Net/log4net.pdb b/lib/log4Net/log4net.pdb
diff --git a/lib/log4Net/log4net.xml b/lib/log4Net/log4net.xml
diff --git a/lib/zookeeper/ZooKeeperNet.dll b/lib/zookeeper/ZooKeeperNet.dll
diff --git a/lib/zookeeper/ZooKeeperNet.pdb b/lib/zookeeper/ZooKeeperNet.pdb
diff --git a/src/Kafka/Kafka.Client/Api/TopicMetadata.cs b/src/Kafka/Kafka.Client/Api/TopicMetadata.cs
@@ -156,7 +156,8 @@ public static PartitionMetadata ReadFrom(ByteBuffer buffer, Dictionary<int, Brok
                 buffer, "error code", Tuple.Create<short, short>(-1, short.MaxValue));
             var partitionId = ApiUtils.ReadIntInRange(buffer, "partition id", Tuple.Create(0, int.MaxValue)); // partition id
             var leaderId = buffer.GetInt();
-            var leader = brokers[leaderId];
+			Broker leader;
+			brokers.TryGetValue(leaderId, out leader);
 
             // list of all replicas
             var numReplicas = ApiUtils.ReadIntInRange(buffer, "number of all replicas", Tuple.Create(0, int.MaxValue));

diff --git a/src/Kafka/Kafka.Client/Common/ClientIdAndBroker.cs b/src/Kafka/Kafka.Client/Common/ClientIdAndBroker.cs
@@ -1,24 +1,57 @@
-namespace Kafka.Client.Common
-{
-    /// <summary>
-    /// Convenience case class since (clientId, brokerInfo) pairs are used to create
-    /// SyncProducer Request Stats and SimpleConsumer Request and Response Stats.
-    /// </summary>
-    public class ClientIdAndBroker
-    {
-        public string ClientId { get; private set; }
-
-        public string BrokerInfo { get; private set; }
-
-        public ClientIdAndBroker(string clientId, string brokerInfo)
-        {
-            this.ClientId = clientId;
-            this.BrokerInfo = brokerInfo;
-        }
-
-        public override string ToString()
-        {
-            return string.Format("{0}-{1}", this.ClientId, this.BrokerInfo);
-        }
-    }
+namespace Kafka.Client.Common
+{
+    /// <summary>
+    /// Convenience case class since (clientId, brokerInfo) pairs are used to create
+    /// SyncProducer Request Stats and SimpleConsumer Request and Response Stats.
+    /// </summary>
+    public class ClientIdAndBroker
+    {
+        public string ClientId { get; private set; }
+
+        public string BrokerInfo { get; private set; }
+
+        public ClientIdAndBroker(string clientId, string brokerInfo)
+        {
+            this.ClientId = clientId;
+            this.BrokerInfo = brokerInfo;
+        }
+
+        public override string ToString()
+        {
+            return string.Format("{0}-{1}", this.ClientId, this.BrokerInfo);
+        }
+
+        protected bool Equals(ClientIdAndBroker other)
+        {
+            return this.ClientId == other.ClientId && this.BrokerInfo == other.BrokerInfo;
+        }
+
+        public override bool Equals(object obj)
+        {
+            if (ReferenceEquals(null, obj))
+            {
+                return false;
+            }
+
+            if (ReferenceEquals(this, obj))
+            {
+                return true;
+            }
+
+            if (obj.GetType() != this.GetType())
+            {
+                return false;
+            }
+
+            return this.Equals((ClientIdAndBroker)obj);
+        }
+
+        public override int GetHashCode()
+        {
+            unchecked
+            {
+                return ((this.ClientId != null ? this.ClientId.GetHashCode() : 0) * 397) ^ (this.BrokerInfo != null ? this.BrokerInfo.GetHashCode() : 0);
+            }
+        }
+    }
 }
diff --git a/src/Kafka/Kafka.Client/Common/Imported/ByteBuffer.cs b/src/Kafka/Kafka.Client/Common/Imported/ByteBuffer.cs
@@ -1,16 +1,19 @@
 namespace Kafka.Client.Common.Imported
 {
-    using System;
-    using System.IO;
-    using System.Net;
-    using System.Text;
-
-    public class ByteBuffer : Stream
+	using log4net;
+	using System;
+	using System.IO;
+	using System.Net;
+	using System.Reflection;
+	using System.Text;
+
+	public class ByteBuffer : Stream
     {
-
-         #region Buffer
+		protected static readonly ILog Logger = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
+
+		#region Buffer
 
-        private int mark = -1;
+		private int mark = -1;
 
         private int position;
 

diff --git a/src/Kafka/Kafka.Client/Consumers/TopicEventHandler.cs b/src/Kafka/Kafka.Client/Consumers/TopicEventHandler.cs
@@ -4,6 +4,6 @@
 
     public interface ITopicEventHandler<T>
     {
-        void HandleTopicEvent(List<T> allTopics);
+        void HandleTopicEvent(IEnumerable<T> allTopics);
     }
 }
diff --git a/src/Kafka/Kafka.Client/Consumers/ZookeeperConsumerConnector.cs b/src/Kafka/Kafka.Client/Consumers/ZookeeperConsumerConnector.cs
@@ -521,7 +521,7 @@ public ZKRebalancerListener(
                 this.watcherExecutorThread.Start();
             }
 
-            public void HandleChildChange(string parentPath, IList<string> curChilds)
+            public void HandleChildChange(string parentPath, IEnumerable<string> curChilds)
             {
                 this.RebalanceEventTriggered();
             }
@@ -1056,7 +1056,7 @@ internal WildcardStreamsHandler(
 
             private readonly ZKGroupDirs dirs;
 
-            public void HandleTopicEvent(List<string> allTopics)
+            public void HandleTopicEvent(IEnumerable<string> allTopics)
             {
                 Logger.Debug("Handling topic event");
                 var updatedTopics = allTopics.Where(topicFilter.IsTopicAllowed).ToList();

diff --git a/src/Kafka/Kafka.Client/Consumers/ZookeeperTopicEventWatcher.cs b/src/Kafka/Kafka.Client/Consumers/ZookeeperTopicEventWatcher.cs
@@ -71,7 +71,7 @@ public ZkTopicEventListener(ZookeeperTopicEventWatcher parent)
                 this.parent = parent;
             }
 
-            public void HandleChildChange(string parentPath, IList<string> currentChilds)
+            public void HandleChildChange(string parentPath, IEnumerable<string> currentChilds)
             {
                 lock (this.parent.@lock)
                 {

diff --git a/src/Kafka/Kafka.Client/Kafka.Client.0.7.0.3.nupkg b/src/Kafka/Kafka.Client/Kafka.Client.0.7.0.3.nupkg
diff --git a/src/Kafka/Kafka.Client/Kafka.Client.0.7.0.4.nupkg b/src/Kafka/Kafka.Client/Kafka.Client.0.7.0.4.nupkg
diff --git a/src/Kafka/Kafka.Client/Kafka.Client.csproj b/src/Kafka/Kafka.Client/Kafka.Client.csproj
@@ -103,7 +103,8 @@
   </PropertyGroup>
   <ItemGroup>
     <Reference Include="Crc32C.NET">
-      <HintPath>..\..\..\lib\Crc32C\Crc32C.NET.dll</HintPath>
+      <HintPath>..\..\..\..\..\..\Tfs\Projects\M\MessageFromKafka\packages\Crc32C.NET.1.0.5.0\lib\net20\Crc32C.NET.dll</HintPath>
+      <Private>True</Private>
     </Reference>
     <Reference Include="log4net">
       <HintPath>..\..\..\lib\log4Net\log4net.dll</HintPath>
@@ -112,7 +113,8 @@
       <HintPath>..\packages\Newtonsoft.Json.6.0.2\lib\net40\Newtonsoft.Json.dll</HintPath>
     </Reference>
     <Reference Include="Snappy.NET">
-      <HintPath>..\..\..\lib\Snappy.NET\Snappy.NET.dll</HintPath>
+      <HintPath>..\..\..\..\..\..\Tfs\Projects\M\MessageFromKafka\packages\Snappy.NET.1.1.1.7\lib\net20\Snappy.NET.dll</HintPath>
+      <Private>True</Private>
     </Reference>
     <Reference Include="Spring.Threading">
       <HintPath>..\..\..\lib\Spring.Threading\Spring.Threading.dll</HintPath>
@@ -124,8 +126,9 @@
     <Reference Include="System.Web.Extensions" />
     <Reference Include="System.XML" />
     <Reference Include="System.Xml.Linq" />
-    <Reference Include="ZooKeeperNet">
-      <HintPath>..\..\..\lib\zookeeper\ZooKeeperNet.dll</HintPath>
+    <Reference Include="ZooKeeperNet, Version=3.3.4.8, Culture=neutral, PublicKeyToken=fefd2c046da35b56, processorArchitecture=MSIL">
+      <HintPath>..\packages\ZooKeeperNet.3.3.4.8\lib\net40\ZooKeeperNet.dll</HintPath>
+      <Private>True</Private>
     </Reference>
   </ItemGroup>
   <ItemGroup>
@@ -288,7 +291,6 @@
     <None Include="KafkaClient.snk" />
     <None Include="packages.config" />
   </ItemGroup>
-  <ItemGroup />
   <Import Project="$(MSBuildToolsPath)\Microsoft.CSharp.targets" />
   <Import Project="$(SolutionDir)\.nuget\NuGet.targets" Condition="Exists('$(SolutionDir)\.nuget\NuGet.targets')" />
   <Target Name="EnsureNuGetPackageBuildImports" BeforeTargets="PrepareForBuild">

diff --git a/src/Kafka/Kafka.Client/Kafka.Client.nuspec b/src/Kafka/Kafka.Client/Kafka.Client.nuspec
@@ -0,0 +1,18 @@
+<?xml version="1.0"?>
+<package >
+  <metadata>
+    <id>Kafka.Client</id>
+    <version>0.7.0.4</version>
+    <title>Kafka .NET</title>
+    <authors>martijnv</authors>
+    <owners>martijnv</owners>
+    <projectUrl>https://github.com/orthrus/kafka-net</projectUrl>
+    <requireLicenseAcceptance>false</requireLicenseAcceptance>
+    <description>This is a .NET implementation of a client for Kafka using C# for Kafka 0.8. It provides for an implementation that covers most basic functionalities to include a simple Producer and Consumer.</description>
+    <copyright>Copyright 2016</copyright>
+    <tags>apache kafka</tags>
+	<dependencies>
+      <dependency id="ZooKeeperNet" version="3.3" />
+    </dependencies>
+  </metadata>
+</package>
diff --git a/src/Kafka/Kafka.Client/Network/Transmission.cs b/src/Kafka/Kafka.Client/Network/Transmission.cs
@@ -46,12 +46,18 @@ internal abstract class Receive : Transmission
         public int ReadCompletely(Stream channel)
         {
             var totalRead = 0;
+			var iter = 0;
             while (!this.complete)
             {
                 var read = this.ReadFrom(channel);
                 Logger.DebugFormat("{0} bytes read", read);
 
                 totalRead += read;
+				iter++;
+				if(iter > 1 && totalRead == 0)
+				{
+					throw new InvalidRequestException("Reading 0 bytes");
+				}
             }
 
             return totalRead;

diff --git a/src/Kafka/Kafka.Client/Properties/AssemblyInfo.cs b/src/Kafka/Kafka.Client/Properties/AssemblyInfo.cs
@@ -26,8 +26,8 @@
 [assembly: AssemblyCopyright("Copyright © ExactTarget 2011")]
 
 [assembly: ComVisible(false)]
-[assembly: AssemblyVersion("0.7.0.3")]
-[assembly: AssemblyFileVersion("0.7.0.3")]
+[assembly: AssemblyVersion("0.7.0.4")]
+[assembly: AssemblyFileVersion("0.7.0.4")]
 [assembly: InternalsVisibleTo("Kafka.Tests")]
 [assembly: InternalsVisibleTo("Kafka.Console")]
 [assembly: CLSCompliant(false)]

diff --git a/src/Kafka/Kafka.Client/Server/AbstractFetcherThread.cs b/src/Kafka/Kafka.Client/Server/AbstractFetcherThread.cs
diff --git a/src/Kafka/Kafka.Client/Utils/ZkUtils.cs b/src/Kafka/Kafka.Client/Utils/ZkUtils.cs
diff --git a/src/Kafka/Kafka.Client/ZKClient/Exceptions/ZkException.cs b/src/Kafka/Kafka.Client/ZKClient/Exceptions/ZkException.cs
@@ -22,7 +22,7 @@ public ZkException(string message, Exception innerException)
 
         public static ZkException Create(KeeperException e)
         {
-            switch (e.GetCode())
+            switch (e.ErrorCode)
             {
                 case KeeperException.Code.NONODE:
                     return new ZkNoNodeException(e.Message, e);

diff --git a/src/Kafka/Kafka.Client/ZKClient/IZkChildListener.cs b/src/Kafka/Kafka.Client/ZKClient/IZkChildListener.cs
@@ -17,6 +17,6 @@ public interface IZkChildListener
         /// </summary>
         /// <param name="parentPath"></param>
         /// <param name="currentChilds"></param>
-        void HandleChildChange(string parentPath, IList<string> currentChilds);
+        void HandleChildChange(string parentPath, IEnumerable<string> currentChilds);
     }
 }
diff --git a/src/Kafka/Kafka.Client/ZKClient/IZkConnection.cs b/src/Kafka/Kafka.Client/ZKClient/IZkConnection.cs
@@ -17,7 +17,7 @@ public interface IZkConnection : IDisposable
 
         bool Exists(string path, bool watch);
 
-        List<string> GetChildren(string path, bool watch);
+        IEnumerable<string> GetChildren(string path, bool watch);
 
         byte[] ReadData(string path, Stat stat, bool watch);
 

diff --git a/src/Kafka/Kafka.Client/ZKClient/ZkClient.cs b/src/Kafka/Kafka.Client/ZKClient/ZkClient.cs
@@ -7,6 +7,7 @@
     using System.Reflection;
     using System.Text;
     using System.Threading;
+	using System.Linq;
 
     using Kafka.Client.Utils;
     using Kafka.Client.ZKClient.Exceptions;
@@ -88,7 +89,7 @@ public ZkClient(IZkConnection zkConnection, int connectionTimeout, IZkSerializer
             this.Connect(connectionTimeout, this);
         }
 
-        public List<string> SubscribeChildChanges(string path, IZkChildListener listener)
+        public IEnumerable<string> SubscribeChildChanges(string path, IZkChildListener listener)
         {
             lock (_childListener)
             {
@@ -368,12 +369,12 @@ private void FireAllEvents()
             }
         }
 
-        public List<string> GetChildren(string path)
+        public IEnumerable<string> GetChildren(string path)
         {
             return this.GetChildren(path, this.HasListeners(path));
         }
 
-        protected List<string> GetChildren(string path, bool watch)
+        protected IEnumerable<string> GetChildren(string path, bool watch)
         {
             return RetryUntilConnected(() => _connection.GetChildren(path, watch));
         }
@@ -387,7 +388,7 @@ public int CountChildren(string path)
         {
             try
             {
-                return GetChildren(path).Count;
+                return GetChildren(path).Count();
             }
             catch (ZkNoNodeException)
             {
@@ -475,8 +476,8 @@ private bool HasListeners(string path)
         }
 
         public bool DeleteRecursive(String path)
-        {
-            List<String> children;
+        {
+			IEnumerable<String> children;
             try
             {
                 children = GetChildren(path, false);
@@ -838,7 +839,7 @@ public void WatchForData(string path)
         /// </summary>
         /// <param name="path"></param>
         /// <returns></returns>
-        public List<String> WatchForChilds(string path)
+        public IEnumerable<String> WatchForChilds(string path)
         {
             if (_zookeeperEventThread != null && Thread.CurrentThread == _zookeeperEventThread)
             {
@@ -934,8 +935,7 @@ public void Dispose()
                 ShutdownTrigger = true;
                 _eventThread.Interrupt();
                 _eventThread.Join(2000);
-                _connection.Dispose();
-                _connection = null;
+
             }
             catch (ThreadInterruptedException e)
             {
@@ -946,7 +946,10 @@ public void Dispose()
                 EventLock.Unlock();
             }
 
-            Logger.Debug("Closing ZkClient...done");
+			_connection.Dispose();
+			_connection = null;
+
+			Logger.Debug("Closing ZkClient...done");
         }
 
         private void Reconnect()

diff --git a/src/Kafka/Kafka.Client/ZKClient/ZkConnection.cs b/src/Kafka/Kafka.Client/ZKClient/ZkConnection.cs
@@ -98,7 +98,7 @@ public bool Exists(string path, bool watch)
             return this._zk.Exists(path, watch) != null;
         }
 
-        public List<string> GetChildren(string path, bool watch) 
+        public IEnumerable<string> GetChildren(string path, bool watch) 
         {
             return this._zk.GetChildren(path, watch);
         }

diff --git a/src/Kafka/Kafka.Client/packages.config b/src/Kafka/Kafka.Client/packages.config
@@ -3,5 +3,6 @@
   <package id="Crc32C.NET" version="1.0.5.0" targetFramework="net40" />
   <package id="Metrics.NET" version="0.1.6" targetFramework="net40" />
   <package id="Newtonsoft.Json" version="6.0.2" targetFramework="net40" />
-  <package id="Snappy.NET" version="1.1.1.8" targetFramework="net40" />
+  <package id="Snappy.NET" version="1.1.1.7" targetFramework="net40" />
+  <package id="ZooKeeperNet" version="3.3.4.8" targetFramework="net40" />
 </packages>
diff --git a/src/Kafka/Kafka.Tests/Kafka.Tests.csproj b/src/Kafka/Kafka.Tests/Kafka.Tests.csproj
@@ -1,124 +1,121 @@
-<?xml version="1.0" encoding="utf-8"?>
-<Project ToolsVersion="4.0" DefaultTargets="Build" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
-  <Import Project="$(MSBuildExtensionsPath)\$(MSBuildToolsVersion)\Microsoft.Common.props" Condition="Exists('$(MSBuildExtensionsPath)\$(MSBuildToolsVersion)\Microsoft.Common.props')" />
-  <PropertyGroup>
-    <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration>
-    <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform>
-    <ProjectGuid>{1794B07A-8B2A-42E6-A700-6BC0E7B8245A}</ProjectGuid>
-    <OutputType>Library</OutputType>
-    <AppDesignerFolder>Properties</AppDesignerFolder>
-    <RootNamespace>Kafka.Tests</RootNamespace>
-    <AssemblyName>Kafka.Tests</AssemblyName>
-    <TargetFrameworkVersion>v4.5</TargetFrameworkVersion>
-    <FileAlignment>512</FileAlignment>
-    <SolutionDir Condition="$(SolutionDir) == '' Or $(SolutionDir) == '*Undefined*'">..\</SolutionDir>
-    <RestorePackages>true</RestorePackages>
-  </PropertyGroup>
-  <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' ">
-    <DebugSymbols>true</DebugSymbols>
-    <DebugType>full</DebugType>
-    <Optimize>false</Optimize>
-    <OutputPath>bin\Debug\</OutputPath>
-    <DefineConstants>DEBUG;TRACE</DefineConstants>
-    <ErrorReport>prompt</ErrorReport>
-    <WarningLevel>4</WarningLevel>
-  </PropertyGroup>
-  <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|AnyCPU' ">
-    <DebugType>pdbonly</DebugType>
-    <Optimize>true</Optimize>
-    <OutputPath>bin\Release\</OutputPath>
-    <DefineConstants>TRACE</DefineConstants>
-    <ErrorReport>prompt</ErrorReport>
-    <WarningLevel>4</WarningLevel>
-  </PropertyGroup>
-  <PropertyGroup>
-    <SignAssembly>false</SignAssembly>
-  </PropertyGroup>
-  <PropertyGroup>
-    <AssemblyOriginatorKeyFile>kafkaclient.snk</AssemblyOriginatorKeyFile>
-  </PropertyGroup>
+<?xml version="1.0" encoding="utf-8"?>
+<Project ToolsVersion="4.0" DefaultTargets="Build" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
+  <Import Project="$(MSBuildExtensionsPath)\$(MSBuildToolsVersion)\Microsoft.Common.props" Condition="Exists('$(MSBuildExtensionsPath)\$(MSBuildToolsVersion)\Microsoft.Common.props')" />
+  <PropertyGroup>
+    <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration>
+    <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform>
+    <ProjectGuid>{1794B07A-8B2A-42E6-A700-6BC0E7B8245A}</ProjectGuid>
+    <OutputType>Library</OutputType>
+    <AppDesignerFolder>Properties</AppDesignerFolder>
+    <RootNamespace>Kafka.Tests</RootNamespace>
+    <AssemblyName>Kafka.Tests</AssemblyName>
+    <TargetFrameworkVersion>v4.5</TargetFrameworkVersion>
+    <FileAlignment>512</FileAlignment>
+    <SolutionDir Condition="$(SolutionDir) == '' Or $(SolutionDir) == '*Undefined*'">..\</SolutionDir>
+    <RestorePackages>true</RestorePackages>
+  </PropertyGroup>
+  <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' ">
+    <DebugSymbols>true</DebugSymbols>
+    <DebugType>full</DebugType>
+    <Optimize>false</Optimize>
+    <OutputPath>bin\Debug\</OutputPath>
+    <DefineConstants>DEBUG;TRACE</DefineConstants>
+    <ErrorReport>prompt</ErrorReport>
+    <WarningLevel>4</WarningLevel>
+  </PropertyGroup>
+  <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|AnyCPU' ">
+    <DebugType>pdbonly</DebugType>
+    <Optimize>true</Optimize>
+    <OutputPath>bin\Release\</OutputPath>
+    <DefineConstants>TRACE</DefineConstants>
+    <ErrorReport>prompt</ErrorReport>
+    <WarningLevel>4</WarningLevel>
+  </PropertyGroup>
+  <PropertyGroup>
+    <SignAssembly>false</SignAssembly>
+  </PropertyGroup>
+  <PropertyGroup>
+    <AssemblyOriginatorKeyFile>kafkaclient.snk</AssemblyOriginatorKeyFile>
+  </PropertyGroup>
   <ItemGroup>
-    <Reference Include="log4net, Version=1.2.10.0, Culture=neutral, PublicKeyToken=1b44e1d426115821, processorArchitecture=MSIL">
-      <SpecificVersion>False</SpecificVersion>
-      <HintPath>..\..\..\lib\log4Net\log4net.dll</HintPath>
+    <Reference Include="log4net">
+      <HintPath>..\..\..\lib\log4Net\log4net.dll</HintPath>
+    </Reference>
+    <Reference Include="Spring.Threading">
+      <HintPath>..\..\..\lib\Spring.Threading\Spring.Threading.dll</HintPath>
+    </Reference>
+    <Reference Include="System" />
+    <Reference Include="System.Configuration" />
+    <Reference Include="System.Core" />
+    <Reference Include="System.Xml.Linq" />
+    <Reference Include="System.Data.DataSetExtensions" />
+    <Reference Include="Microsoft.CSharp" />
+    <Reference Include="System.Data" />
+    <Reference Include="System.Xml" />
+    <Reference Include="xunit">
+      <HintPath>..\packages\xunit.1.9.2\lib\net20\xunit.dll</HintPath>
     </Reference>
-    <Reference Include="Spring.Threading, Version=1.0.0.22880, Culture=neutral, PublicKeyToken=b745dc0af8c84db9, processorArchitecture=MSIL">
-      <SpecificVersion>False</SpecificVersion>
-      <HintPath>..\Kafka.Client\bin\Debug\Spring.Threading.dll</HintPath>
-    </Reference>
-    <Reference Include="System" />
-    <Reference Include="System.Configuration" />
-    <Reference Include="System.Core" />
-    <Reference Include="System.Xml.Linq" />
-    <Reference Include="System.Data.DataSetExtensions" />
-    <Reference Include="Microsoft.CSharp" />
-    <Reference Include="System.Data" />
-    <Reference Include="System.Xml" />
-    <Reference Include="xunit">
-      <HintPath>..\packages\xunit.1.9.2\lib\net20\xunit.dll</HintPath>
-    </Reference>
-    <Reference Include="ZooKeeperNet, Version=3.3.4.1, Culture=neutral, PublicKeyToken=fefd2c046da35b56, processorArchitecture=MSIL">
-      <SpecificVersion>False</SpecificVersion>
-      <HintPath>..\..\..\lib\zookeeper\ZooKeeperNet.dll</HintPath>
-    </Reference>
-  </ItemGroup>
-  <ItemGroup>
-    <Compile Include="Api\ApiUtilsTest.cs" />
-    <Compile Include="Api\SerializationTestUtils.cs" />
-    <Compile Include="Common\ConfigTest.cs" />
-    <Compile Include="Consumers\ConsumerIteratorTest.cs" />
-    <Compile Include="Consumers\TopicFilterTest.cs" />
-    <Compile Include="Consumers\ZookeeperConsumerConnectorTest.cs" />
-    <Compile Include="Custom\Extensions\BitOrder.cs" />
-    <Compile Include="Custom\Extensions\RandomExtensions.cs" />
-    <Compile Include="Custom\Server\TempZookeeperConfig.cs" />
-    <Compile Include="Custom\Server\TempKafkaConfig.cs" />
-    <Compile Include="Integration\AutoOffsetResetTest.cs" />
-    <Compile Include="Integration\FetcherTest.cs" />
-    <Compile Include="Integration\KafkaServerTestHarness.cs" />
-    <Compile Include="Integration\LazyInitProducerTest.cs" />
-    <Compile Include="Integration\PrimitiveApiTest.cs" />
-    <Compile Include="Integration\ProducerConsumerTestHarness.cs" />
-    <Compile Include="Integration\TopicMetadataTest.cs" />
-    <Compile Include="Messages\ByteBufferMessageSetTest.cs" />
-    <Compile Include="Custom\Utils\IteratorTemplateTests.cs" />
-    <Compile Include="Messages\MessageCompressionTest.cs" />
-    <Compile Include="Messages\MessageTest.cs" />
-    <Compile Include="Producers\AsyncProducerTest.cs" />
-    <Compile Include="Producers\ProducerTest.cs" />
-    <Compile Include="Producers\SyncProducerTest.cs" />
-    <Compile Include="Properties\AssemblyInfo.cs" />
-    <Compile Include="Utils\KafkaRunClassHelper.cs" />
-    <Compile Include="Utils\TestUtils.cs" />
-    <Compile Include="Utils\TestUtil.cs" />
-    <Compile Include="Zk\ZKEphemeralTest.cs" />
-    <Compile Include="Zk\ZooKeeperTestHarness.cs" />
-  </ItemGroup>
-  <ItemGroup>
-    <None Include="App.config" />
-    <None Include="kafkaclient.snk" />
-    <None Include="packages.config" />
-  </ItemGroup>
-  <ItemGroup>
-    <ProjectReference Include="..\Kafka.Client\Kafka.Client.csproj">
-      <Project>{a92dd03b-ee4f-4a78-9fb2-279b6348c7d2}</Project>
-      <Name>Kafka.Client</Name>
-    </ProjectReference>
-  </ItemGroup>
-  <ItemGroup />
-  <Import Project="$(MSBuildToolsPath)\Microsoft.CSharp.targets" />
-  <Import Project="$(SolutionDir)\.nuget\NuGet.targets" Condition="Exists('$(SolutionDir)\.nuget\NuGet.targets')" />
-  <Target Name="EnsureNuGetPackageBuildImports" BeforeTargets="PrepareForBuild">
-    <PropertyGroup>
-      <ErrorText>This project references NuGet package(s) that are missing on this computer. Enable NuGet Package Restore to download them.  For more information, see http://go.microsoft.com/fwlink/?LinkID=322105. The missing file is {0}.</ErrorText>
-    </PropertyGroup>
-    <Error Condition="!Exists('$(SolutionDir)\.nuget\NuGet.targets')" Text="$([System.String]::Format('$(ErrorText)', '$(SolutionDir)\.nuget\NuGet.targets'))" />
-  </Target>
-  <!-- To modify your build process, add your task inside one of the targets below and uncomment it. 
-       Other similar extension points exist, see Microsoft.Common.targets.
-  <Target Name="BeforeBuild">
-  </Target>
-  <Target Name="AfterBuild">
+    <Reference Include="ZooKeeperNet">
+      <HintPath>..\..\..\lib\zookeeper\ZooKeeperNet.dll</HintPath>
+    </Reference>
+  </ItemGroup>
+  <ItemGroup>
+    <Compile Include="Api\ApiUtilsTest.cs" />
+    <Compile Include="Api\SerializationTestUtils.cs" />
+    <Compile Include="Common\ConfigTest.cs" />
+    <Compile Include="Consumers\ConsumerIteratorTest.cs" />
+    <Compile Include="Consumers\TopicFilterTest.cs" />
+    <Compile Include="Consumers\ZookeeperConsumerConnectorTest.cs" />
+    <Compile Include="Custom\Extensions\BitOrder.cs" />
+    <Compile Include="Custom\Extensions\RandomExtensions.cs" />
+    <Compile Include="Custom\Server\TempZookeeperConfig.cs" />
+    <Compile Include="Custom\Server\TempKafkaConfig.cs" />
+    <Compile Include="Integration\AutoOffsetResetTest.cs" />
+    <Compile Include="Integration\FetcherTest.cs" />
+    <Compile Include="Integration\KafkaServerTestHarness.cs" />
+    <Compile Include="Integration\LazyInitProducerTest.cs" />
+    <Compile Include="Integration\PrimitiveApiTest.cs" />
+    <Compile Include="Integration\ProducerConsumerTestHarness.cs" />
+    <Compile Include="Integration\TopicMetadataTest.cs" />
+    <Compile Include="Messages\ByteBufferMessageSetTest.cs" />
+    <Compile Include="Custom\Utils\IteratorTemplateTests.cs" />
+    <Compile Include="Messages\MessageCompressionTest.cs" />
+    <Compile Include="Messages\MessageTest.cs" />
+    <Compile Include="Producers\AsyncProducerTest.cs" />
+    <Compile Include="Producers\ProducerTest.cs" />
+    <Compile Include="Producers\SyncProducerTest.cs" />
+    <Compile Include="Properties\AssemblyInfo.cs" />
+    <Compile Include="Utils\KafkaRunClassHelper.cs" />
+    <Compile Include="Utils\TestUtils.cs" />
+    <Compile Include="Utils\TestUtil.cs" />
+    <Compile Include="Zk\ZKEphemeralTest.cs" />
+    <Compile Include="Zk\ZooKeeperTestHarness.cs" />
+  </ItemGroup>
+  <ItemGroup>
+    <None Include="App.config" />
+    <None Include="kafkaclient.snk" />
+    <None Include="packages.config" />
+  </ItemGroup>
+  <ItemGroup>
+    <ProjectReference Include="..\Kafka.Client\Kafka.Client.csproj">
+      <Project>{a92dd03b-ee4f-4a78-9fb2-279b6348c7d2}</Project>
+      <Name>Kafka.Client</Name>
+    </ProjectReference>
+  </ItemGroup>
+  <ItemGroup />
+  <Import Project="$(MSBuildToolsPath)\Microsoft.CSharp.targets" />
+  <Import Project="$(SolutionDir)\.nuget\NuGet.targets" Condition="Exists('$(SolutionDir)\.nuget\NuGet.targets')" />
+  <Target Name="EnsureNuGetPackageBuildImports" BeforeTargets="PrepareForBuild">
+    <PropertyGroup>
+      <ErrorText>This project references NuGet package(s) that are missing on this computer. Enable NuGet Package Restore to download them.  For more information, see http://go.microsoft.com/fwlink/?LinkID=322105. The missing file is {0}.</ErrorText>
+    </PropertyGroup>
+    <Error Condition="!Exists('$(SolutionDir)\.nuget\NuGet.targets')" Text="$([System.String]::Format('$(ErrorText)', '$(SolutionDir)\.nuget\NuGet.targets'))" />
+  </Target>
+  <!-- To modify your build process, add your task inside one of the targets below and uncomment it. 
+       Other similar extension points exist, see Microsoft.Common.targets.
+  <Target Name="BeforeBuild">
+  </Target>
+  <Target Name="AfterBuild">
   </Target>
-  -->
+  -->
 </Project>
diff --git a/src/Kafka/packages/Snappy.NET.1.1.1.7/Snappy.NET.1.1.1.7.nupkg b/src/Kafka/packages/Snappy.NET.1.1.1.7/Snappy.NET.1.1.1.7.nupkg
diff --git a/src/Kafka/packages/Snappy.NET.1.1.1.7/lib/net20/Snappy.NET.dll b/src/Kafka/packages/Snappy.NET.1.1.1.7/lib/net20/Snappy.NET.dll
diff --git a/src/Kafka/packages/Snappy.NET.1.1.1.7/lib/net20/Snappy.NET.xml b/src/Kafka/packages/Snappy.NET.1.1.1.7/lib/net20/Snappy.NET.xml
diff --git a/src/Kafka/packages/Snappy.NET.1.1.1.7/lib/net45/Snappy.NET.dll b/src/Kafka/packages/Snappy.NET.1.1.1.7/lib/net45/Snappy.NET.dll
diff --git a/src/Kafka/packages/Snappy.NET.1.1.1.7/lib/net45/Snappy.NET.xml b/src/Kafka/packages/Snappy.NET.1.1.1.7/lib/net45/Snappy.NET.xml
diff --git a/src/Kafka/packages/ZooKeeperNet.3.3.4.8/ZooKeeperNet.3.3.4.8.nupkg b/src/Kafka/packages/ZooKeeperNet.3.3.4.8/ZooKeeperNet.3.3.4.8.nupkg
diff --git a/src/Kafka/packages/ZooKeeperNet.3.3.4.8/lib/net40/ZooKeeperNet.dll b/src/Kafka/packages/ZooKeeperNet.3.3.4.8/lib/net40/ZooKeeperNet.dll