feat: add support for vendor-specific topic configuration

src/LEGO.AsyncAPI.Bindings/Kafka/KafkaChannelBinding.cs

@@ -4,7 +4,6 @@ namespace LEGO.AsyncAPI.Bindings.Kafka
 {
     using System;
     using LEGO.AsyncAPI.Models;
-    using LEGO.AsyncAPI.Models.Bindings.Kafka;
     using LEGO.AsyncAPI.Readers.ParseNodes;
     using LEGO.AsyncAPI.Writers;
 
@@ -47,10 +46,11 @@ public class KafkaChannelBinding : ChannelBinding<KafkaChannelBinding>
         private static FixedFieldMap<TopicConfigurationObject> kafkaChannelTopicConfigurationObjectFixedFields = new ()
         {
             { "cleanup.policy", (a, n) => { a.CleanupPolicy = n.CreateSimpleList(s => s.GetScalarValue()); } },
-            { "retention.ms", (a, n) => { a.RetentionMiliseconds = n.GetIntegerValue(); } },
+            { "retention.ms", (a, n) => { a.RetentionMilliseconds = n.GetIntegerValue(); } },
             { "retention.bytes", (a, n) => { a.RetentionBytes = n.GetIntegerValue(); } },
-            { "delete.retention.ms", (a, n) => { a.DeleteRetentionMiliseconds = n.GetIntegerValue(); } },
+            { "delete.retention.ms", (a, n) => { a.DeleteRetentionMilliseconds = n.GetIntegerValue(); } },
             { "max.message.bytes", (a, n) => { a.MaxMessageBytes = n.GetIntegerValue(); } },
+            { "custom.configs", (a, n) => { a.CustomConfigs = n.CreateSimpleMap(s => s.GetScalarValue()); } },
         };
 
         /// <summary>

src/LEGO.AsyncAPI.Bindings/Kafka/TopicConfigurationObject.cs

@@ -1,11 +1,13 @@
 // Copyright (c) The LEGO Group. All rights reserved.
 
-namespace LEGO.AsyncAPI.Models.Bindings.Kafka
+using System;
+using System.Collections.Generic;
+using LEGO.AsyncAPI.Models;
+using LEGO.AsyncAPI.Models.Interfaces;
+using LEGO.AsyncAPI.Writers;
+
+namespace LEGO.AsyncAPI.Bindings.Kafka
 {
-    using System;
-    using System.Collections.Generic;
-    using LEGO.AsyncAPI.Models.Interfaces;
-    using LEGO.AsyncAPI.Writers;
 
     public class TopicConfigurationObject : IAsyncApiElement
     {
@@ -17,7 +19,7 @@ public class TopicConfigurationObject : IAsyncApiElement
         /// <summary>
         /// The retention.ms configuration option.
         /// </summary>
-        public int? RetentionMiliseconds { get; set; }
+        public int? RetentionMilliseconds { get; set; }
 
         /// <summary>
         /// The retention.bytes configuration option.
@@ -27,12 +29,17 @@ public class TopicConfigurationObject : IAsyncApiElement
         /// <summary>
         /// The delete.retention.ms configuration option.
         /// </summary>
-        public int? DeleteRetentionMiliseconds { get; set; }
+        public int? DeleteRetentionMilliseconds { get; set; }
 
         /// <summary>
         /// The max.message.bytes configuration option.
         /// </summary>
         public int? MaxMessageBytes { get; set; }
+
+        /// <summary>
+        /// The custom.configs properties configuration option.
+        /// </summary>
+        public Dictionary<string, string>? CustomConfigs { get; set; }
 
         public void Serialize(IAsyncApiWriter writer)
         {
@@ -43,10 +50,11 @@ public void Serialize(IAsyncApiWriter writer)
 
             writer.WriteStartObject();
             writer.WriteOptionalCollection(AsyncApiConstants.CleanupPolicy, this.CleanupPolicy, (w, s) => w.WriteValue(s));
-            writer.WriteOptionalProperty<int>(AsyncApiConstants.RetentionMiliseconds, this.RetentionMiliseconds);
+            writer.WriteOptionalProperty<int>(AsyncApiConstants.RetentionMilliseconds, this.RetentionMilliseconds);
             writer.WriteOptionalProperty<int>(AsyncApiConstants.RetentionBytes, this.RetentionBytes);
-            writer.WriteOptionalProperty<int>(AsyncApiConstants.DeleteRetentionMiliseconds, this.DeleteRetentionMiliseconds);
+            writer.WriteOptionalProperty<int>(AsyncApiConstants.DeleteRetentionMilliseconds, this.DeleteRetentionMilliseconds);
             writer.WriteOptionalProperty<int>(AsyncApiConstants.MaxMessageBytes, this.MaxMessageBytes);
+            writer.WriteOptionalMap(AsyncApiConstants.CustomConfigs, this.CustomConfigs, (w, t) => w.WriteValue(t));
             writer.WriteEndObject();
         }
     }

src/LEGO.AsyncAPI/Models/AsyncApiConstants.cs

@@ -132,10 +132,11 @@ public static class AsyncApiConstants
         public const string ServerVariables = "serverVariables";
         public const string MessageId = "messageId";
         public const string CleanupPolicy = "cleanup.policy";
-        public const string RetentionMiliseconds = "retention.ms";
+        public const string RetentionMilliseconds = "retention.ms";
         public const string RetentionBytes = "retention.bytes";
-        public const string DeleteRetentionMiliseconds = "delete.retention.ms";
+        public const string DeleteRetentionMilliseconds = "delete.retention.ms";
         public const string MaxMessageBytes = "max.message.bytes";
+        public const string CustomConfigs = "custom.configs";
         public const string TopicConfiguration = "topicConfiguration";
         public const string GeoReplication = "geo-replication";
         public const string AdditionalItems = "additionalItems";

test/LEGO.AsyncAPI.Tests/Bindings/Kafka/KafkaBindings_Should.cs

@@ -2,14 +2,13 @@
 
 namespace LEGO.AsyncAPI.Tests.Bindings.Kafka
 {
+    using System.Collections.Generic;
     using FluentAssertions;
     using LEGO.AsyncAPI.Bindings;
     using LEGO.AsyncAPI.Bindings.Kafka;
     using LEGO.AsyncAPI.Models;
-    using LEGO.AsyncAPI.Models.Bindings.Kafka;
     using LEGO.AsyncAPI.Readers;
     using NUnit.Framework;
-    using System.Collections.Generic;
 
     internal class KafkaBindings_Should
     {
@@ -30,7 +29,10 @@ public void KafkaChannelBinding_WithFilledObject_SerializesAndDeserializes()
       retention.ms: 1
       retention.bytes: 2
       delete.retention.ms: 3
-      max.message.bytes: 4";
+      max.message.bytes: 4
+      custom.configs:
+        key.schema.validation: 'true'
+        key.subject.name.strategy: TopicNameStrategy";
 
             var channel = new AsyncApiChannel();
             channel.Bindings.Add(new KafkaChannelBinding
@@ -41,11 +43,17 @@ public void KafkaChannelBinding_WithFilledObject_SerializesAndDeserializes()
                 TopicConfiguration = new TopicConfigurationObject()
                 {
                     CleanupPolicy = new List<string> { "delete", "compact" },
-                    RetentionMiliseconds = 1,
+                    RetentionMilliseconds = 1,
                     RetentionBytes = 2,
-                    DeleteRetentionMiliseconds = 3,
+                    DeleteRetentionMilliseconds = 3,
                     MaxMessageBytes = 4,
+                    CustomConfigs = new Dictionary<string, string>
+                    {
+                        { "key.schema.validation", "true" },
+                        { "key.subject.name.strategy", "TopicNameStrategy" }
+                    },
                 },
+
             });
 
             // Act