diff --git a/src/LEGO.AsyncAPI.Bindings/Kafka/KafkaChannelBinding.cs b/src/LEGO.AsyncAPI.Bindings/Kafka/KafkaChannelBinding.cs index 82a18968..c172772b 100644 --- a/src/LEGO.AsyncAPI.Bindings/Kafka/KafkaChannelBinding.cs +++ b/src/LEGO.AsyncAPI.Bindings/Kafka/KafkaChannelBinding.cs @@ -47,7 +47,7 @@ public class KafkaChannelBinding : ChannelBinding private static FixedFieldMap kafkaChannelTopicConfigurationObjectFixedFields = new () { { "cleanup.policy", (a, n) => { a.CleanupPolicy = n.CreateSimpleList(s => s.GetScalarValue()); } }, - { "retention.ms", (a, n) => { a.RetentionMilliseconds = n.GetIntegerValue(); } }, + { "retention.ms", (a, n) => { a.RetentionMilliseconds = n.GetLongValue(); } }, { "retention.bytes", (a, n) => { a.RetentionBytes = n.GetIntegerValue(); } }, { "delete.retention.ms", (a, n) => { a.DeleteRetentionMilliseconds = n.GetIntegerValue(); } }, { "max.message.bytes", (a, n) => { a.MaxMessageBytes = n.GetIntegerValue(); } }, diff --git a/test/LEGO.AsyncAPI.Tests/Bindings/Kafka/KafkaBindings_Should.cs b/test/LEGO.AsyncAPI.Tests/Bindings/Kafka/KafkaBindings_Should.cs index 32f83748..26525652 100644 --- a/test/LEGO.AsyncAPI.Tests/Bindings/Kafka/KafkaBindings_Should.cs +++ b/test/LEGO.AsyncAPI.Tests/Bindings/Kafka/KafkaBindings_Should.cs @@ -27,7 +27,7 @@ public void KafkaChannelBinding_WithFilledObject_SerializesAndDeserializes() cleanup.policy: - delete - compact - retention.ms: 2592000000 + retention.ms: 15552000000 retention.bytes: 2 delete.retention.ms: 3 max.message.bytes: 4 @@ -45,7 +45,7 @@ public void KafkaChannelBinding_WithFilledObject_SerializesAndDeserializes() TopicConfiguration = new TopicConfigurationObject() { CleanupPolicy = new List { "delete", "compact" }, - RetentionMilliseconds = 2592000000, + RetentionMilliseconds = 15552000000, RetentionBytes = 2, DeleteRetentionMilliseconds = 3, MaxMessageBytes = 4,