Merge branch '1.0.x'

Author: mhowlett

examples/AvroSpecific/Program.cs

@@ -70,7 +70,7 @@ static async Task Main(string[] args)
             };
 
             // Note: The User class in this project was generated using the Confluent fork of the avrogen.exe tool 
-            // (avaliable from: https://github.com/confluentinc/avro/tree/confluent-fork) which includes modifications
+            // (available from: https://github.com/confluentinc/avro/tree/confluent-fork) which includes modifications
             // that prevent namespace clashes with user namespaces that include the identifier 'Avro'. AvroSerializer
             // and AvroDeserializer are also compatible with classes generated by the official avrogen.exe tool 
             // (available from: https://github.com/apache/avro), with the above limitation.

examples/Consumer/Program.cs

@@ -142,7 +142,7 @@ public static void Run_ManualAssign(string brokerList, List<string> topics, Canc
                 BootstrapServers = brokerList,
                 // partition offsets can be committed to a group even by consumers not
                 // subscribed to the group. in this example, auto commit is disabled
-                // to prevent this from occuring.
+                // to prevent this from occurring.
                 EnableAutoCommit = true
             };
 

src/ConfigGen/Program.cs

@@ -17,7 +17,7 @@ internal class MappingConfiguration
         ///     these property types are specified here.
         /// </summary>
         /// <remarks>
-        ///     sasl.mechanisms is an awkward case becasue the values contain '-' characters (and 
+        ///     sasl.mechanisms is an awkward case because the values contain '-' characters (and 
         ///     there are other values that contain the '_' character, so can't 1:1 map with this).
         ///     This type is defined by hand later.
         /// </remarks>

src/Confluent.Kafka/AdminClient.cs

@@ -145,7 +145,7 @@ private Task StartPollTask(CancellationToken ct)
                                 if (adminClientResult.GetType() != expectedType)
                                 {
                                     // Should never happen.
-                                    throw new InvalidOperationException($"Completion source type mismatch. Exected {expectedType.Name}, got {type}");
+                                    throw new InvalidOperationException($"Completion source type mismatch. Expected {expectedType.Name}, got {type}");
                                 }
 
                                 var errorCode = Librdkafka.event_error(eventPtr);

src/Confluent.Kafka/Config_gen.cs

@@ -801,7 +801,7 @@ public ProducerConfig() {}
         public int? CompressionLevel { get { return GetInt("compression.level"); } set { this.SetObject("compression.level", value); } }
 
         /// <summary>
-        ///     When set to `true`, the producer will ensure that messages are successfully produced exactly once and in the original produce order. The following configuration properties are adjusted automatically (if not modified by the user) when idempotence is enabled: `max.in.flight.requests.per.connection=5` (must be less than or equal to 5), `retries=INT32_MAX` (must be greater than 0), `acks=all`, `queuing.strategy=fifo`. Producer instantation will fail if user-supplied configuration is incompatible.
+        ///     When set to `true`, the producer will ensure that messages are successfully produced exactly once and in the original produce order. The following configuration properties are adjusted automatically (if not modified by the user) when idempotence is enabled: `max.in.flight.requests.per.connection=5` (must be less than or equal to 5), `retries=INT32_MAX` (must be greater than 0), `acks=all`, `queuing.strategy=fifo`. Producer instantiation will fail if user-supplied configuration is incompatible.
         ///
         ///     default: false
         ///     importance: high

src/Confluent.Kafka/ConsumeResult.cs

@@ -46,7 +46,7 @@ public TopicPartition TopicPartition
             => new TopicPartition(Topic, Partition);
 
         /// <summary>
-        ///     The TopicPartitionOffset assoicated with the message.
+        ///     The TopicPartitionOffset associated with the message.
         /// </summary>
         public TopicPartitionOffset TopicPartitionOffset
         {

src/Confluent.Kafka/ConsumerBuilder.cs

@@ -221,7 +221,7 @@ public ConsumerBuilder<TKey, TValue> SetValueDeserializer(IDeserializer<TValue>
         ///     Note: corresponding to every call to this handler there will be a corresponding call to
         ///     the partitions revoked handler (if one has been set using SetPartitionsRevokedHandler).
         ///
-        ///     The actual partitions to consume from and start offsets are specfied by the return value
+        ///     The actual partitions to consume from and start offsets are specified by the return value
         ///     of the handler. This set of partitions is not required to match the assignment provided
         ///     by the consumer group, but typically will. Partition offsets may be a specific offset, or
         ///     special value (Beginning, End or Unset). If Unset, consumption will resume from the

src/Confluent.Kafka/DeliveryReport.cs

@@ -28,7 +28,7 @@ public class DeliveryReport<TKey, TValue> : DeliveryResult<TKey, TValue>
         public Error Error { get; set; }
 
         /// <summary>
-        ///     The TopicPartitionOffsetError assoicated with the message.
+        ///     The TopicPartitionOffsetError associated with the message.
         /// </summary>
         public TopicPartitionOffsetError TopicPartitionOffsetError
         {

src/Confluent.Kafka/DeliveryResult.cs

@@ -44,7 +44,7 @@ public TopicPartition TopicPartition
             => new TopicPartition(Topic, Partition);
 
         /// <summary>
-        ///     The TopicPartitionOffset assoicated with the message.
+        ///     The TopicPartitionOffset associated with the message.
         /// </summary>
         public TopicPartitionOffset TopicPartitionOffset
         {

src/Confluent.Kafka/ErrorCode.cs

@@ -475,7 +475,7 @@ public enum ErrorCode
         IllegalSaslState = 34,
 
         /// <summary>
-        ///     Unusupported version
+        ///     Unsupported version
         /// </summary>
         UnsupportedVersion = 35,
 
@@ -520,7 +520,7 @@ public enum ErrorCode
         UnsupportedForMessageFormat = 43,
 
         /// <summary>
-        ///     Isolation policy volation
+        ///     Isolation policy violation
         /// </summary>
         PolicyViolation = 44,