remove non-serializing Producer and Consumer classes (#760)

* added SchemaRegistryConfigBasicAuthCredentialsSource

* review changes

* actually ran the integration tests this time

* badly formatted xml comment fix

* remove base classes + byte[] clients

* removed ProducerCore (base)

* delivery handler -> internal

* internal -> private

* removed pointless summaries

* remove out of date commnet

Author: mhowlett

src/ConfigGen/Program.cs

@@ -436,9 +436,9 @@ public ConsumerConfig() {}
 
         /// <summary>
         ///     A comma separated list of fields that may be optionally set
-        ///     in <see cref=""Confluent.Kafka.ConsumeResult{TKey, TValue}"" />
+        ///     in <see cref=""Confluent.Kafka.ConsumeResult{TKey,TValue}"" />
         ///     objects returned by the
-        ///     <see cref=""Confluent.Kafka.Consumer.Consume(System.TimeSpan)"" />
+        ///     <see cref=""Confluent.Kafka.Consumer{TKey,TValue}.Consume(System.TimeSpan)"" />
         ///     method. Disabling fields that you do not require will improve 
         ///     throughput and reduce memory consumption. Allowed values:
         ///     headers, timestamp, topic, all, none

src/Confluent.Kafka/AdminClient.cs

@@ -485,7 +485,7 @@ internal AdminClient(AdminClientBuilder builder)
             }
 
             // build a producer instance to use as the underlying client.
-            var producerBuilder = new ProducerBuilder(config);
+            var producerBuilder = new ProducerBuilder<Null, Null>(config);
             if (builder.LogHandler != null) { producerBuilder.SetLogHandler((_, logMessage) => builder.LogHandler(this, logMessage)); }
             if (builder.ErrorHandler != null) { producerBuilder.SetErrorHandler((_, error) => builder.ErrorHandler(this, error)); }
             if (builder.StatisticsHandler != null) { producerBuilder.SetStatisticsHandler((_, stats) => builder.StatisticsHandler(this, stats)); }

src/Confluent.Kafka/ConfigPropertyNames.cs

@@ -66,9 +66,9 @@ public static class Consumer
         {
             /// <summary>
             ///     A comma separated list of fields that may be optionally set
-            ///     in <see cref="Confluent.Kafka.ConsumeResult{TKey, TValue}" />
+            ///     in <see cref="Confluent.Kafka.ConsumeResult{TKey,TValue}" />
             ///     objects returned by the
-            ///     <see cref="Confluent.Kafka.Consumer.Consume(System.TimeSpan)" />
+            ///     <see cref="Confluent.Kafka.Consumer{TKey,TValue}.Consume(System.TimeSpan)" />
             ///     method. Disabling fields that you do not require will improve 
             ///     throughput and reduce memory consumption. Allowed values:
             ///     headers, timestamp, topic, all, none

src/Confluent.Kafka/Config_gen.cs

@@ -876,9 +876,9 @@ public ConsumerConfig() {}
 
         /// <summary>
         ///     A comma separated list of fields that may be optionally set
-        ///     in <see cref="Confluent.Kafka.ConsumeResult{TKey, TValue}" />
+        ///     in <see cref="Confluent.Kafka.ConsumeResult{TKey,TValue}" />
         ///     objects returned by the
-        ///     <see cref="Confluent.Kafka.Consumer.Consume(System.TimeSpan)" />
+        ///     <see cref="Confluent.Kafka.Consumer{TKey,TValue}.Consume(System.TimeSpan)" />
         ///     method. Disabling fields that you do not require will improve 
         ///     throughput and reduce memory consumption. Allowed values:
         ///     headers, timestamp, topic, all, none

src/Confluent.Kafka/ConsumeException.cs

@@ -36,7 +36,7 @@ public class ConsumeException : KafkaException
         /// <param name="error">
         ///     The error that occured.
         /// </param>
-        public ConsumeException(ConsumeResult consumerRecord, Error error)
+        public ConsumeException(ConsumeResult<byte[], byte[]> consumerRecord, Error error)
             : base(error)
         {
             ConsumerRecord = consumerRecord;
@@ -46,6 +46,6 @@ public ConsumeException(ConsumeResult consumerRecord, Error error)
         ///     An object that provides information known about the consumer
         ///     record for which the error occured.
         /// </summary>
-        public ConsumeResult ConsumerRecord { get; private set; }
+        public ConsumeResult<byte[], byte[]> ConsumerRecord { get; private set; }
     }
 }

src/Confluent.Kafka/ConsumeResult.cs

@@ -19,11 +19,6 @@
 
 namespace Confluent.Kafka
 {
-    /// <summary>
-    ///     Represents a message consumed from a Kafka cluster.
-    /// </summary>
-    public class ConsumeResult : ConsumeResult<byte[], byte[]> {}
-
     /// <summary>
     ///     Represents a message consumed from a Kafka cluster.
     /// </summary>