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

feat: allow use of cluster defined values for topic creation #555

Closed robertcoltheart closed 7 months ago

robertcoltheart commented 7 months ago

Description

If passing -1 for NumPartitions or ReplicationFactor when creating topics, the creation will use the cluster-default values for these values. This change allows for defaulting to using cluster values, and over-riding them if required. This reduces a lot of boilerplate code when setting up a cluster in code.

How Has This Been Tested?

Added integration tests to test this against a Kafka instance.

Checklist

Disclaimer

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