use IConsumer/IProducer (#878)

Author: AndyPook

src/Confluent.Kafka/ConsumerBuilder.cs

@@ -39,17 +39,17 @@ public class ConsumerBuilder<TKey, TValue>
         /// <summary>
         ///     The configured error handler.
         /// </summary>
-        internal protected Action<Consumer<TKey, TValue>, Error> ErrorHandler { get; set; }
+        internal protected Action<IConsumer<TKey, TValue>, Error> ErrorHandler { get; set; }
 
         /// <summary>
         ///     The configured log handler.
         /// </summary>
-        internal protected Action<Consumer<TKey, TValue>, LogMessage> LogHandler { get; set; }
+        internal protected Action<IConsumer<TKey, TValue>, LogMessage> LogHandler { get; set; }
 
         /// <summary>
         ///     The configured statistics handler.
         /// </summary>
-        internal protected Action<Consumer<TKey, TValue>, string> StatisticsHandler { get; set; }
+        internal protected Action<IConsumer<TKey, TValue>, string> StatisticsHandler { get; set; }
 
         /// <summary>
         ///     The configured key deserializer.
@@ -141,7 +141,7 @@ public ConsumerBuilder(IEnumerable<KeyValuePair<string, string>> config)
         ///     Executes as a side-effect of the Consume method (on the same thread).
         /// </remarks>
         public ConsumerBuilder<TKey, TValue> SetStatisticsHandler(
-            Action<Consumer<TKey, TValue>, string> statisticsHandler)
+            Action<IConsumer<TKey, TValue>, string> statisticsHandler)
         {
             if (this.StatisticsHandler != null)
             {
@@ -161,7 +161,7 @@ public ConsumerBuilder<TKey, TValue> SetStatisticsHandler(
         ///     Executes as a side-effect of the Consume method (on the same thread).
         /// </remarks>
         public ConsumerBuilder<TKey, TValue> SetErrorHandler(
-            Action<Consumer<TKey, TValue>, Error> errorHandler)
+            Action<IConsumer<TKey, TValue>, Error> errorHandler)
         {
             if (this.ErrorHandler != null)
             {
@@ -188,7 +188,7 @@ public ConsumerBuilder<TKey, TValue> SetErrorHandler(
         ///     prolonged operations.
         /// </remarks>
         public ConsumerBuilder<TKey, TValue> SetLogHandler(
-            Action<Consumer<TKey, TValue>, LogMessage> logHandler)
+            Action<IConsumer<TKey, TValue>, LogMessage> logHandler)
         {
             if (this.LogHandler != null)
             {

src/Confluent.Kafka/ProducerBuilder.cs

@@ -33,17 +33,17 @@ public class ProducerBuilder<TKey, TValue>
         /// <summary>
         ///     The configured error handler.
         /// </summary>
-        internal protected Action<Producer<TKey, TValue>, Error> ErrorHandler { get; set; }
+        internal protected Action<IProducer<TKey, TValue>, Error> ErrorHandler { get; set; }
 
         /// <summary>
         ///     The configured log handler.
         /// </summary>
-        internal protected Action<Producer<TKey, TValue>, LogMessage> LogHandler { get; set; }
+        internal protected Action<IProducer<TKey, TValue>, LogMessage> LogHandler { get; set; }
 
         /// <summary>
         ///     The configured statistics handler.
         /// </summary>
-        internal protected Action<Producer<TKey, TValue>, string> StatisticsHandler { get; set; }
+        internal protected Action<IProducer<TKey, TValue>, string> StatisticsHandler { get; set; }
 
 
         /// <summary>
@@ -108,7 +108,7 @@ public ProducerBuilder(IEnumerable<KeyValuePair<string, string>> config)
         ///     Executes on the poll thread (by default, a background thread managed by
         ///     the producer).
         /// </remarks>
-        public ProducerBuilder<TKey, TValue> SetStatisticsHandler(Action<Producer<TKey, TValue>, string> statisticsHandler)
+        public ProducerBuilder<TKey, TValue> SetStatisticsHandler(Action<IProducer<TKey, TValue>, string> statisticsHandler)
         {
             if (this.StatisticsHandler != null)
             {
@@ -128,7 +128,7 @@ public ProducerBuilder<TKey, TValue> SetStatisticsHandler(Action<Producer<TKey,
         ///     Executes on the poll thread (by default, a background thread managed by
         ///     the producer).
         /// </remarks>
-        public ProducerBuilder<TKey, TValue> SetErrorHandler(Action<Producer<TKey, TValue>, Error> errorHandler)
+        public ProducerBuilder<TKey, TValue> SetErrorHandler(Action<IProducer<TKey, TValue>, Error> errorHandler)
         {
             if (this.ErrorHandler != null)
             {
@@ -154,7 +154,7 @@ public ProducerBuilder<TKey, TValue> SetErrorHandler(Action<Producer<TKey, TValu
         ///     Confluent.Kafka APIs from within a log handler or perform any
         ///     prolonged operations.
         /// </remarks>
-        public ProducerBuilder<TKey, TValue> SetLogHandler(Action<Producer<TKey, TValue>, LogMessage> logHandler)
+        public ProducerBuilder<TKey, TValue> SetLogHandler(Action<IProducer<TKey, TValue>, LogMessage> logHandler)
         {
             if (this.LogHandler != null)
             {