IClusterManager interface
Provides access to Cluster administration
public interface IClusterManager
Members
| name | description |
|---|---|
| ClusterName { get; } | Gets the unique cluster name defined in the configuration |
| CreateIfNotExistsAsync(…) | Create Topics when building Cluster Configuration if the topic doesn't exist. |
| GetConsumerGroupOffsetsAsync(…) | Retrieves the offsets for a specified consumer group and a collection of topics. The offsets indicate where the consumer group is in its consumption of the topics. |
| GetTopicMetadataAsync(…) | Retrieves the metadata for a specified topic. This includes information about the topic as well as its partitions. |
See Also
- namespace KafkaFlow.Clusters