@@ -47,9 +47,9 @@ public class KafkaChannelBinding : ChannelBinding<KafkaChannelBinding>
47
47
private static FixedFieldMap < TopicConfigurationObject > kafkaChannelTopicConfigurationObjectFixedFields = new ( )
48
48
{
49
49
{ "cleanup.policy" , ( a , n ) => { a . CleanupPolicy = n . CreateSimpleList ( s => s . GetScalarValue ( ) ) ; } } ,
50
- { "retention.ms" , ( a , n ) => { a . RetentionMilliseconds = n . GetIntegerValue ( ) ; } } ,
51
- { "retention.bytes" , ( a , n ) => { a . RetentionBytes = n . GetIntegerValue ( ) ; } } ,
52
- { "delete.retention.ms" , ( a , n ) => { a . DeleteRetentionMilliseconds = n . GetIntegerValue ( ) ; } } ,
50
+ { "retention.ms" , ( a , n ) => { a . RetentionMilliseconds = n . GetLongValue ( ) ; } } ,
51
+ { "retention.bytes" , ( a , n ) => { a . RetentionBytes = n . GetLongValue ( ) ; } } ,
52
+ { "delete.retention.ms" , ( a , n ) => { a . DeleteRetentionMilliseconds = n . GetLongValue ( ) ; } } ,
53
53
{ "max.message.bytes" , ( a , n ) => { a . MaxMessageBytes = n . GetIntegerValue ( ) ; } } ,
54
54
{ "confluent.key.schema.validation" , ( a , n ) => { a . ConfluentKeySchemaValidation = n . GetBooleanValue ( ) ; } } ,
55
55
{ "confluent.key.subject.name.strategy" , ( a , n ) => { a . ConfluentKeySubjectName = n . GetScalarValue ( ) ; } } ,
0 commit comments