IClusterManager.CreateIfNotExistsAsync method
Create Topics when building Cluster Configuration if the topic doesn't exist.
public Task CreateIfNotExistsAsync(IEnumerable<TopicConfiguration> configuration)
| parameter | description |
|---|---|
| configuration | Topics to create |
See Also
- class TopicConfiguration
- interface IClusterManager
- namespace KafkaFlow.Clusters