From 48b6f83b2a3bf8b87c80076b28f1cf3ec0588285 Mon Sep 17 00:00:00 2001 From: "adam.gloyne" Date: Fri, 16 Feb 2024 09:52:05 +0000 Subject: [PATCH] fix other retention values --- src/LEGO.AsyncAPI.Bindings/Kafka/KafkaChannelBinding.cs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/LEGO.AsyncAPI.Bindings/Kafka/KafkaChannelBinding.cs b/src/LEGO.AsyncAPI.Bindings/Kafka/KafkaChannelBinding.cs index c172772b..b6185cd4 100644 --- a/src/LEGO.AsyncAPI.Bindings/Kafka/KafkaChannelBinding.cs +++ b/src/LEGO.AsyncAPI.Bindings/Kafka/KafkaChannelBinding.cs @@ -48,8 +48,8 @@ public class KafkaChannelBinding : ChannelBinding { { "cleanup.policy", (a, n) => { a.CleanupPolicy = n.CreateSimpleList(s => s.GetScalarValue()); } }, { "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(); } }, + { "retention.bytes", (a, n) => { a.RetentionBytes = n.GetLongValue(); } }, + { "delete.retention.ms", (a, n) => { a.DeleteRetentionMilliseconds = n.GetLongValue(); } }, { "max.message.bytes", (a, n) => { a.MaxMessageBytes = n.GetIntegerValue(); } }, { "confluent.key.schema.validation", (a, n) => { a.ConfluentKeySchemaValidation = n.GetBooleanValue(); } }, { "confluent.key.subject.name.strategy", (a, n) => { a.ConfluentKeySubjectName = n.GetScalarValue(); } },