Binary Producer with Span<T>

src/ConfigGen/ConfigGen.csproj

@@ -3,7 +3,6 @@
   <PropertyGroup>
     <OutputType>Exe</OutputType>
     <TargetFramework>net6.0</TargetFramework>
-    <LangVersion>7.1</LangVersion>
   </PropertyGroup>
 
   <ItemGroup>

src/Confluent.Kafka/DeliveryReport.cs

@@ -17,6 +17,35 @@
 
 namespace Confluent.Kafka
 {
+    /// <summary>
+    ///     The result of a produce request.
+    /// </summary>
+    public class DeliveryReport : DeliveryResult
+    {
+        /// <summary>
+        ///     An error (or NoError) associated with the message.
+        /// </summary>
+        public Error Error { get; set; }
+
+        /// <summary>
+        ///     The TopicPartitionOffsetError associated with the message.
+        /// </summary>
+        public TopicPartitionOffsetError TopicPartitionOffsetError
+        {
+            get
+            {
+                return new TopicPartitionOffsetError(Topic, Partition, Offset, Error);
+            }
+            set
+            {
+                Topic = value.Topic;
+                Partition = value.Partition;
+                Offset = value.Offset;
+                Error = value.Error;
+            }
+        }
+    }
+
     /// <summary>
     ///     The result of a produce request.
     /// </summary>

src/Confluent.Kafka/DeliveryResult.cs

@@ -20,7 +20,7 @@ namespace Confluent.Kafka
     /// <summary>
     ///     Encapsulates the result of a successful produce request.
     /// </summary>
-    public class DeliveryResult<TKey, TValue>
+    public class DeliveryResult
     {
         /// <summary>
         ///     The topic associated with the message.
@@ -64,7 +64,24 @@ public TopicPartitionOffset TopicPartitionOffset
         ///     The persistence status of the message
         /// </summary>
         public PersistenceStatus Status { get; set; }
-
+
+        /// <summary>
+        ///     The Kafka message timestamp.
+        /// </summary>
+        public virtual Timestamp Timestamp { get; set; }
+
+        /// <summary>
+        ///     The Kafka message headers.
+        /// </summary>
+        public virtual Headers Headers { get; set; }
+    }
+
+
+    /// <summary>
+    ///     Encapsulates the result of a successful produce request.
+    /// </summary>
+    public class DeliveryResult<TKey, TValue> : DeliveryResult
+    {
         /// <summary>
         ///     The Kafka message.
         /// </summary>
@@ -88,19 +105,15 @@ public TValue Value
             set { Message.Value = value; }
         }
 
-        /// <summary>
-        ///     The Kafka message timestamp.
-        /// </summary>
-        public Timestamp Timestamp
+        /// <inheritdoc />
+        public override Timestamp Timestamp
         {
             get { return Message.Timestamp; }
             set { Message.Timestamp = value; }
         }
 
-        /// <summary>
-        ///     The Kafka message headers.
-        /// </summary>
-        public Headers Headers
+        /// <inheritdoc />
+        public override Headers Headers
         {
             get { return Message.Headers; }
             set { Message.Headers = value; }

src/Confluent.Kafka/DependentProducerBuilder.cs

@@ -21,19 +21,47 @@
 namespace Confluent.Kafka
 {
     /// <summary>
-    ///     A builder class for <see cref="IProducer{TKey, TValue}" /> instance
+    ///     A builder class for <see cref="IProducer" /> instance
     ///     implementations that leverage an existing client handle.
     ///
     ///     [API-SUBJECT-TO-CHANGE] - This class may be removed in the future
     ///     in favor of an improved API for this functionality.
     /// </summary>
-    public class DependentProducerBuilder<TKey, TValue>
+    public class DependentProducerBuilder
     {
         /// <summary>
         ///     The configured client handle.
         /// </summary>
         public Handle Handle { get; set; }
-
+
+        /// <summary>
+        ///     An underlying librdkafka client handle that the Producer will use to 
+        ///     make broker requests. The handle must be from another Producer
+        ///     instance (not Consumer or AdminClient).
+        /// </summary>
+        public DependentProducerBuilder(Handle handle)
+        {
+            this.Handle = handle;
+        }
+
+        /// <summary>
+        ///     Build a new IProducer implementation instance.
+        /// </summary>
+        public virtual IProducer Build()
+        {
+            return new Producer(this);
+        }
+    }
+
+    /// <summary>
+    ///     A builder class for <see cref="IProducer{TKey, TValue}" /> instance
+    ///     implementations that leverage an existing client handle.
+    ///
+    ///     [API-SUBJECT-TO-CHANGE] - This class may be removed in the future
+    ///     in favor of an improved API for this functionality.
+    /// </summary>
+    public class DependentProducerBuilder<TKey, TValue> : DependentProducerBuilder
+    {
         /// <summary>
         ///     The configured key serializer.
         /// </summary>
@@ -60,9 +88,8 @@ public class DependentProducerBuilder<TKey, TValue>
         ///     make broker requests. The handle must be from another Producer
         ///     instance (not Consumer or AdminClient).
         /// </summary>
-        public DependentProducerBuilder(Handle handle)
+        public DependentProducerBuilder(Handle handle) : base(handle)
         {
-            this.Handle = handle;
         }
 
         /// <summary>
@@ -104,7 +131,7 @@ public DependentProducerBuilder<TKey, TValue> SetValueSerializer(IAsyncSerialize
         /// <summary>
         ///     Build a new IProducer implementation instance.
         /// </summary>
-        public virtual IProducer<TKey, TValue> Build()
+        public new virtual IProducer<TKey, TValue> Build()
         {
             return new Producer<TKey, TValue>(this);
         }

src/Confluent.Kafka/Headers.cs

@@ -27,7 +27,7 @@ namespace Confluent.Kafka
     /// <remarks>
     ///     Message headers are supported by v0.11 brokers and above.
     /// </remarks>
-    public class Headers : IEnumerable<IHeader>
+    public class Headers : IReadOnlyCollection<IHeader>
     {
         private readonly List<IHeader> headers = new List<IHeader>();
 

src/Confluent.Kafka/IConsumer.cs

@@ -673,7 +673,7 @@ public interface IConsumer<TKey, TValue> : IClient
         ///     The current consumer group metadata associated with this consumer,
         ///     or null if a GroupId has not been specified for the consumer.
         ///     This metadata object should be passed to the transactional producer's
-        ///     <see cref="IProducer{K,V}.SendOffsetsToTransaction(IEnumerable{TopicPartitionOffset},IConsumerGroupMetadata,TimeSpan)"/>
+        ///     <see cref="ITransactionalProducer.SendOffsetsToTransaction(IEnumerable{TopicPartitionOffset},IConsumerGroupMetadata,TimeSpan)"/>
         ///     method.
         /// </summary>
         IConsumerGroupMetadata ConsumerGroupMetadata { get; }