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