Farfetch / kafkaflow

Apache Kafka .NET Framework to create applications simple to use and extend.
https://farfetch.github.io/kafkaflow/
MIT License
653 stars 118 forks source link

Extend TopicConfiguration to support dynamic configuration when creating topics #570

Open shlomiassaf opened 5 months ago

shlomiassaf commented 5 months ago

Description

Dynamic values are valid input when creating a topic.

The PR will allow adding them, so for example, one can provide the retention period and cleanup policy of the topic:

         clusterManager.CreateIfNotExistsAsync("mytopic", 1, 1, new Dictionary<string, string>
          {
              { "retention.ms", (86400000 * 2).ToString() }, // 2 days
              { "cleanup.policy", "delete" }
          });

Checklist

Disclaimer

By sending us your contributions, you are agreeing that your contribution is made subject to the terms of our Contributor Ownership Statement