masesgroup/KEFCore

Cleanup policy `delete` can be too much strong in some conditions

Closed this issue · 0 comments

masesdevelopers commented

The following is the current default for a topic will be created:

KEFCore/src/net/KEFCore/Storage/Internal/KafkaCluster.cs

Line 200 in 08250f4

Options.TopicConfig.CleanupPolicy = MASES.KNet.Common.TopicConfigBuilder.CleanupPolicyTypes.Compact | MASES.KNet.Common.TopicConfigBuilder.CleanupPolicyTypes.Delete;

However cleanup policy delete can be too much strong if the data shall remain for a longest period in the topic, so can be added a new options which helps to create the property with that option. The default will be only compact.