ClusterConfigurationBuilderExtensions.EnableAdminMessages method
Creates the admin producer and consumer to manage the application consumers
public static IClusterConfigurationBuilder EnableAdminMessages(
this IClusterConfigurationBuilder cluster, string topic, string consumerGroup = null,
int topicPartition = 0)
| parameter | description |
|---|---|
| cluster | The cluster configuration builder |
| topic | The topic to be used by the admin commands |
| consumerGroup | The consumer group prefix |
| topicPartition | The partition used to produce and consumer admin messages |
See Also
- class ClusterConfigurationBuilderExtensions
- namespace KafkaFlow